live555 server + mediacodec

java端建立快取檔案, 開啟camera preview並呼叫mediacodec編碼攝像頭預覽資料，把視訊編碼資料寫入快取檔案，呼叫jni端live555的H264VideoFileServerMediaSubsession建立H.264視訊檔案流服務子會話（簡單驗證實時的視訊流服務功能，檔案寫入、讀出方式實現視訊流服務的方式，效率比較低）

Java端：
StreamerActivity2:

 static {
         ...
         System.loadLibrary("live555");
       System.loadLibrary("streamer"
 
);
    }

    ...
    public static native void end();
    public static native void RtspTempFile(String filename);  //1、建立快取檔案
    public static native void WriteRtspFrame(byte[] data, int size); //jni端寫編碼資料入快取檔案，測試用   
    public static native int  RtspServer(String filename);    //2、呼叫live555的H264VideoFileServerMediaSubsession，實現.264視訊檔案媒體會話子服務
 


    //yv12 轉 yuv420p  yvu -> yuv  
    private void swapYV12toI420(byte[] yv12bytes, byte[] i420bytes, int width, int height)   
    {        
        System.arraycopy(yv12bytes, 0, i420bytes, 0,width*height);  
        System.arraycopy(yv12bytes, width*height+width*height/4, i420bytes, width*height,width*height/4
 
);  
        System.arraycopy(yv12bytes, width*height, i420bytes, width*height+width*height/4,width*height/4);    
    } 

    // MediaCodec（型別為"video/avc"） 同步編碼
    public void onFrame(byte[] buf, int length) {        
            swapYV12toI420(buf, h264, width, height); 

            ByteBuffer[] inputBuffers = mediaCodec.getInputBuffers();
            ByteBuffer[] outputBuffers = mediaCodec.getOutputBuffers();
            int inputBufferIndex = mediaCodec.dequeueInputBuffer(-1);
            if (inputBufferIndex >= 0) {
                ByteBuffer inputBuffer = inputBuffers[inputBufferIndex];
                inputBuffer.clear();
                inputBuffer.put(h264, 0, length);
                mediaCodec.queueInputBuffer(inputBufferIndex, 0, length, 0, 0);
            }
            MediaCodec.BufferInfo bufferInfo = new MediaCodec.BufferInfo();
            int outputBufferIndex = mediaCodec.dequeueOutputBuffer(bufferInfo,0);
            while (outputBufferIndex >= 0) {
                ByteBuffer outputBuffer = outputBuffers[outputBufferIndex];

              byte[] outData = new byte[bufferInfo.size];
              outputBuffer.get(outData);
                    if(runOneFlag){
                         if(outData.length == 21){
                              System.arraycopy(outData, 0,  outData0, 0, 21); //暫存sps pps，編碼器會一次性輸出sps和pps包（sps pps長度因視訊高、寬等引數會有差異，
                                                                              //編碼器輸出的nalu單元自動帶start code）
                              runOneFlag = false;
                         }
                    }
                    runPushFlag = true;
                    if(runPushFlag)
                    {
                         if(runTestFlag)
                         {
                             frame_count2++;
                             if(frame_count2 >= 50){ //快取50幀
                                  runTestFlag = false;
                                  new Thread() {
                                       @Override
                                       public void run() {
                                            RtspServer(h264Path); //開啟RTSPServer的 H264VideoFileServerMediaSubsession
                                       }
                                 }.start();
                             }
                         }
                       try {
                             outputStream.write(outData, 0, outData.length); //nalu資料，jav端a寫入.264檔案, outputStream = new BufferedOutputStream(new FileOutputStream(**));
                         } catch (IOException e) {
                             // TODO Auto-generated catch block
                             e.printStackTrace();
                         }
                    }
                    //WriteRtspFrame(outData, outData.length);  //nalu資料，jni端寫入.264檔案
                mediaCodec.releaseOutputBuffer(outputBufferIndex, false);
                outputBufferIndex = mediaCodec.dequeueOutputBuffer(bufferInfo, 0);
            }
      }

JNI端：
streamer.cpp:

JNIEXPORT jint JNICALL Java_com_example_mylive55servermediacodec_StreamerActivity2_RtspServer
(JNIEnv *env1, jobject obj, jstring filename)
{
    TaskScheduler* scheduler = BasicTaskScheduler::createNew();
    UsageEnvironment* env = BasicUsageEnvironment::createNew(*scheduler);

    UserAuthenticationDatabase* authDB = NULL;

    RTSPServer* rtspServer = RTSPServer::createNew(*env, 8554, authDB);
    if (rtspServer == NULL) {
        LOGI("Failed to create RTSP server:%s", env->getResultMsg());
        return -1;
    }
    char const* descriptionString = "Session streamed by \"testOnDemandRTSPServer\"";

    quit = 0;
    ServerMediaSession* sms = NULL;
    // A H.264 video elementary stream:
    {
        char const* streamName = "mstreamer";
        char const* inputFileName = env1->GetStringUTFChars(filename, NULL); 

        LOGI("   inputFileName = %s", inputFileName);
      sms = ServerMediaSession::createNew(*env, streamName, streamName, descriptionString);
        sms->addSubsession(H264VideoFileServerMediaSubsession::createNew(*env, inputFileName, reuseFirstSource0));
        rtspServer->addServerMediaSession(sms);

        announceStream0(rtspServer, sms, streamName, inputFileName);
    }
  /*
    {
        char const* streamName = "ts";
        char const* inputFileName = "/sdcard/H264_720p.ts";
        char const* indexFileName = "test.tsx";
        ServerMediaSession* sms = ServerMediaSession::createNew(*env,
                streamName, streamName, descriptionString);
        sms->addSubsession(
                MPEG2TransportFileServerMediaSubsession::createNew(*env,
                        inputFileName, indexFileName, reuseFirstSource0));
        rtspServer->addServerMediaSession(sms);

        announceStream0(rtspServer, sms, streamName, inputFileName);
    }
  */
    if (rtspServer->setUpTunnelingOverHTTP(80)
            || rtspServer->setUpTunnelingOverHTTP(8000)
            || rtspServer->setUpTunnelingOverHTTP(8080)) {
        LOGI("we use port-->%d", rtspServer->httpServerPortNum());
    } else {
        LOGI("RTSP-over-HTTP tunneling is not available.");
    }

    env->taskScheduler().doEventLoop(&quit);

    rtspServer->removeServerMediaSession(sms);
    Medium::close(rtspServer);

    env->reclaim();
    env = NULL;
  delete scheduler;
    scheduler = NULL;

    LOGI("......End......\n");

    return 0;
}

JNIEXPORT void JNICALL Java_com_example_mylive55servermediacodec_StreamerActivity2_end(JNIEnv *env, jobject obj) {
     LOGI("Ending streaming...\n");
     quit = 1;
     // Medium::close(rtspServer);
}

JNIEXPORT void JNICALL Java_com_example_mylive55servermediacodec_StreamerActivity2_RtspTempFile
(JNIEnv *env, jobject obj, jstring filename)
{
    char const*inputFilename0 = env->GetStringUTFChars(filename, NULL);
    inputFilename = inputFilename0;

    file = fopen(inputFilename0, "wb+");
    if (!file) {
        LOGE("couldn't open %s", inputFilename0);
        exit(1);
    }

    LOGE("  RtspTempFile open %s  ", inputFilename0);
}

//新增視訊幀的方法
JNIEXPORT void JNICALL Java_com_example_mylive55servermediacodec_StreamerActivity2_WriteRtspFrame(
        JNIEnv *env, jclass clz, jbyteArray data, jint size)
{
    unsigned char *buf = (unsigned char *)env->GetByteArrayElements(data, JNI_FALSE);
    //length
    pthread_mutex_lock(&mutex);
  int ret = fwrite(buf, 1, size, file);
  if(ret != 0){
       LOGI(" IDR = %d, %d", ret, size);
  }
  pthread_mutex_unlock(&mutex);
    env->ReleaseByteArrayElements(data, (jbyte *)buf, 0);
}