首先說下為什麼要做這樣一個東西

          在上家公司的時候，作為客戶端開發，一個月要給領導演示異常app的開發成果，當時用的策略是用錄屏類軟體，錄製成mp4，然後通過投影播放mp4檔案，來給領導看。這樣做帶來的問題是，要提前準備mp4需要時間，領導想要看除了mp4外的內容時，體驗不好。自己對流媒體知識有一些瞭解，所以就想做一個直播android螢幕的app，這就是想做這樣一個東西的原因。

說下為什麼選擇rtsp協議

          本來是想用rtmp來做流媒體協議的，如果用rtmp，手機作為推流端，將視訊推給rtmp伺服器，vlc等客戶端可以播放。但是這樣做還需要一個流媒體伺服器，所以選擇了rtsp協議。

          思路是：手機端作為rtsp服務端，vlc作為客戶端，通過rtp協議來傳輸視訊流。這樣做就省去了搭建流媒體服務的工作。這樣做事參考了github上開源專案spydroid來做的。本專案所有功能使用java實現。

結構簡述

程式碼簡析

android採集螢幕視訊資料

這一步內容，可以看我之前的一片部落格，連線如下：

rtsp server端的搭建

rtsp協議的互動過程

rtsp的簡單互動過，以此app為例，來簡單說下：

1.vlc傳送OPTIONS報文到server端，server端根據計算結果，返回200 ok或者其他錯誤；

2.vlc傳送DESCRIBE報文，server返回報文，報文中的欄位，感興趣的同學可以自己搜尋下；

3.vlc傳送SETUP報文，server返回，如果setup成功，server端會進行rtp傳送的準備工作；

這一步還是比較關鍵的，服務端會告訴客戶端Transport用的是rtp/udp還是rtp/tcp，告訴客戶端一些埠的相關資訊。

4.vlc傳送PLAY報文，server返回；

5.如果播放結束，客戶端可以傳送TEARDOWN報文，一次完整的RTSP互動結束。

程式碼實現簡述

本專案用的rtsp server端程式碼，是從GITHUB開源專案spydroid中摘取的，感情去的同學可以看下這個專案，程式碼些的很好。

工程中rtsp涉及到的檔案如下：

RtspServer整合android Service，是整個rtsp功能部分的入口檔案。

流處理類的繼承關係： ScreenStream->VideoStream->MediaStream->Stream，ScreenStream為自己實現，VideoStream,MediaStream為抽象類，定義了關於流的一些基本的屬性集方法，比如設定sps pps 埠等。

h264打包rtp的整合關係： H264Packetizer->AbstractPacketizer，下面這個核心功能函式的作用就是講264幀打包成rtp包的作用

private void send() throws IOException, InterruptedException {
		int sum = 1, len = 0, type;

		if (streamType == 0) {
			// NAL units are preceeded by their length, we parse the length
			fill(header,0,5);
			ts += delay;
			naluLength = header[3]&0xFF | (header[2]&0xFF)<<8 | (header[1]&0xFF)<<16 | (header[0]&0xFF)<<24;

			if (naluLength>100000 || naluLength<0) resync();
		} else if (streamType == 1) {
			// NAL units are preceeded with 0x00000001
			fill(header,0,5);
			ts = ((ScreenInputStream)is). getLastts();
			//ts += delay;
			naluLength = is.available();
			Log.d(TAG,"header is  "+header[0]+" "+header[1]+" "+header[2]+" "+header[3]+" "+header[4]+"  ts = "+ts+" nalu len = "+naluLength+"");
			if (!(header[0]==0 && header[1]==0 && header[2]==0)) {
				// Turns out, the NAL units are not preceeded with 0x00000001
				Log.e(TAG, "NAL units are not preceeded by 0x00000001");
				streamType = 2;
				return;
			}
		} else {
			// Nothing preceededs the NAL units
			fill(header,0,1);
			header[4] = header[0];
			ts = ((ScreenInputStream)is). getLastts();
			//ts += delay;
			naluLength = is.available()+1;
		}

		// Parses the NAL unit type
		type = header[4]&0x1F;

		Log.d(TAG,"NAL type is "+type+"");

		// The stream already contains NAL unit type 7 or 8, we don't need
		// to add them to the stream ourselves
		if (type == 7 || type == 8) {
			Log.v(TAG,"SPS or PPS present in the stream.");
			count++;
			if (count>4) {
				sps = null;
				pps = null;
			}
		}

		//Log.d(TAG,"- Nal unit length: " + naluLength + " delay: "+delay/1000000+" type: "+type);

		// Small NAL unit => Single NAL unit 
		if (naluLength<=MAXPACKETSIZE-rtphl-2) {
			buffer = socket.requestBuffer();
			buffer[rtphl] = header[4];
			len = fill(buffer, rtphl+1,  naluLength-1);
			socket.updateTimestamp(ts);
			socket.markNextPacket();
			super.send(naluLength+rtphl);
			//Log.d(TAG,"----- Single NAL unit - len:"+len+" delay: "+delay);
		}
		// Large NAL unit => Split nal unit 
		else {

			// Set FU-A header
			header[1] = (byte) (header[4] & 0x1F);  // FU header type
			header[1] += 0x80; // Start bit
			// Set FU-A indicator
			header[0] = (byte) ((header[4] & 0x60) & 0xFF); // FU indicator NRI
			header[0] += 28;

			while (sum < naluLength) {
				buffer = socket.requestBuffer();
				buffer[rtphl] = header[0];
				buffer[rtphl+1] = header[1];
				socket.updateTimestamp(ts);
				if ((len = fill(buffer, rtphl+2,  naluLength-sum > MAXPACKETSIZE-rtphl-2 ? MAXPACKETSIZE-rtphl-2 : naluLength-sum  ))<0) return; sum += len;
				// Last packet before next NAL
				if (sum >= naluLength) {
					// End bit on
					buffer[rtphl+1] += 0x40;
					socket.markNextPacket();
				}
				super.send(len+rtphl+2);
				// Switch start bit
				header[1] = (byte) (header[1] & 0x7F);
				//Log.d(TAG,"----- FU-A unit, sum:"+sum);
			}
		}
	}

RtpSocket類的作用：將打包好的rtp包通過socket傳送，這個類用的是多播udp傳送的。

該類繼承Runnable介面，在該執行緒中進行資料的傳送，包括rtcp報文

/** The Thread sends the packets in the FIFO one by one at a constant rate. */
	@Override
	public void run() {
		Statistics stats = new Statistics(50,3000);
		try {
			// Caches mCacheSize milliseconds of the stream in the FIFO.
			Thread.sleep(mCacheSize);
			long delta = 0;
			while (mBufferCommitted.tryAcquire(4,TimeUnit.SECONDS)) {
				if (mOldTimestamp != 0) {
					// We use our knowledge of the clock rate of the stream and the difference between two timestamps to
					// compute the time lapse that the packet represents.
					if ((mTimestamps[mBufferOut]-mOldTimestamp)>0) {
						stats.push(mTimestamps[mBufferOut]-mOldTimestamp);
						long d = stats.average()/1000000;
						//Log.d(TAG,"delay: "+d+" d: "+(mTimestamps[mBufferOut]-mOldTimestamp)/1000000);
						// We ensure that packets are sent at a constant and suitable rate no matter how the RtpSocket is used.
						if (mCacheSize>0) Thread.sleep(d);
					} else if ((mTimestamps[mBufferOut]-mOldTimestamp)<0) {
						Log.e(TAG, "TS: "+mTimestamps[mBufferOut]+" OLD: "+mOldTimestamp);
					}
					delta += mTimestamps[mBufferOut]-mOldTimestamp;
					if (delta>500000000 || delta<0) {
						//Log.d(TAG,"permits: "+mBufferCommitted.availablePermits());
						delta = 0;
					}
				}
				mReport.update(mPackets[mBufferOut].getLength(), System.nanoTime(),(mTimestamps[mBufferOut]/100L)*(mClock/1000L)/10000L);
				mOldTimestamp = mTimestamps[mBufferOut];
				if (mCount++>30) mSocket.send(mPackets[mBufferOut]);
				if (++mBufferOut>=mBufferCount) mBufferOut = 0;
				mBufferRequested.release();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		mThread = null;
		resetFifo();
	}

Session SessionBuilder為Session管理類，每一個客戶端的連線都是一個Session物件

SendReport為傳送RTCP報文的管理類

目前只實現了視訊功能，音訊功能暫未實現

run該工程後，app啟動後，介面目前很簡單，頂部會有rtsp的地址，比如：rtsp://192.168.60.120:8086。中間有倆按鈕，開始錄屏和結束錄屏，點選開始錄屏，此時會啟動rtsp server，MediaCodec會將螢幕yuv編碼為h264。此時就可以在vlc中輸入rtsp地址，就可以播放了。

Session SessionBuilder為Session管理類，每一個客戶端的連線都是一個Session物件

SendReport為傳送RTCP報文的管理類，