(3)事件處理類：RtspServerHandler.java

publicclass RtspServerHandler extends SimpleChannelHandler {

@Override

publicvoid channelOpen(ChannelHandlerContext ctx, ChannelStateEvent e)

throws Exception {

// TODO Auto-generated method stub

super.channelOpen(ctx, e);

LOGGER.info("Rtsp伺服器端channel opened :"+ctx.getChannel().getRemoteAddress());

    }

@Override

publicvoid channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e)

throws Exception {

// TODO Auto-generated method stub

super.channelConnected(ctx, e);

LOGGER.info("Rtsp伺服器端channel connected");

    }

privatestaticfinal Logger LOGGER = Logger.getLogger(RtspServerHandler.class);

@Override

publicvoid messageReceived(ChannelHandlerContext ctx, MessageEvent e)

throws Exception {

       HttpRequest objMessage = (HttpRequest) e.getMessage();

LOGGER.info("Rtsp伺服器端接收到資料:"+objMessage);

if(objMessage instanceof HttpRequest){

//         DefaultHttpRequest request = (DefaultHttpRequest) objMessage;

//         HttpRequest req = new DefaultHttpRequest(RtspVersions.RTSP_1_0,RtspMethods.PLAY, "shanglenidexindewodexinhaoshangxin.mp3");

//         e.getChannel().write(req);

//         if(request.getContent() instanceof CompositeChannelBuffer){

//            CompositeChannelBuffer ccb = (CompositeChannelBuffer) request.getContent();

//            byte[] b0 = ccb.getBuffer(0).array();

//            System.out.println(Utils.bytesToHex(b0));

//            byte[] b1 = ccb.getBuffer(b0.length).array();

//            System.out.println(Utils.bytesToHex(b1));

//           

//         }

           writeMsg(objMessage,e.getFuture().getChannel());

       }

    }

privatevoid writeMsg(HttpRequest request , Channel channel) throws IOException{

    ChannelBuffer cbuffer = new DynamicChannelBuffer(8192);

//  cbuffer.writeBytes("hello".getBytes(Constants.UTF8ENCODER));

    DefaultHttpResponse response = new DefaultHttpResponse(RtspVersions.RTSP_1_0, RtspResponseStatuses.OK);

if (request.getMethod().equals(RtspMethods.DESCRIBE)) {

LOGGER.info("DESCRIBE,流向：C-->S;引數要求：推薦；功能：檢查演示或媒體物件的描述，也允許使用接收頭指定使用者理解的描述格式。DESCRIBE的答覆-響應組成媒體RTSP初始階段");

       } elseif (request.getMethod().equals(RtspMethods.ANNOUNCE)) {

LOGGER.info("ANNOUNCE,流向：C<-->S;引數要求：可選；功能：當從使用者發往伺服器時，ANNOUNCE將請求URL識別的演示或媒體物件描述傳送給伺服器；反之，ANNOUNCE實時更新連線描述。如新媒體流加入演示，整個演示描述再次傳送，而不僅僅是附加元件，使元件能被刪除");

       } elseif (request.getMethod().equals(RtspMethods.GET_PARAMETER)) {

LOGGER.info("GET_PARAMETER,流向：C<-->S;引數要求：可選；功能：GET_PARAMETER請求檢查RUL指定的演示與媒體的引數值。沒有實體體時，GET_PARAMETER也許能用來測試使用者與伺服器的連通情況");

       } elseif (request.getMethod().equals(RtspMethods.OPTIONS)) {

LOGGER.info("OPTIONS,流向：C<-->S;引數要求：要求；功能：可在任意時刻發出OPTIONS請求，如使用者打算嘗試非標準請求，並不影響伺服器狀態");

       } elseif (request.getMethod().equals(RtspMethods.PAUSE)) {

LOGGER.info("PAUSE,流向：C-->S;引數要求：推薦；功能：PAUSE請求引起流傳送臨時中斷。如請求URL命名一個流，僅回放和記錄被停止；如請求URL命名一個演示或流組，演示或組中所有當前活動的流傳送都停止。恢復回放或記錄後，必須維持同步。在SETUP訊息中連線頭超時引數所指定時段期間被暫停後，儘管伺服器可能關閉連線並釋放資源，但伺服器資源會被預訂");

       } elseif (request.getMethod().equals(RtspMethods.PLAY)) {

LOGGER.info("PLAY,流向：C-->S;引數要求：要求；功能：PLAY告訴伺服器以SEFUP指定的機制開始傳送資料；直到一些SETUP請求被成功響應，客戶端才可釋出PLAY請求。PLAY請求將正常播放時間設定在所指定範圍的起始處，傳送流資料直到範圍的結束處。PLAY請求可排成佇列，伺服器將PLAY請求排成佇列，順序執行");

       } elseif (request.getMethod().equals(RtspMethods.RECORD)) {

LOGGER.info("RECORD,流向：C-->S;引數要求：可選；功能：該方法根據演示描述初始化媒體資料記錄範圍，時標反映開始和結束時間；如沒有給出時間範圍，使用演示描述提供的開始和結束時間。如連線已經啟動，立即開始記錄，伺服器資料請求URL或其他URL決定是否儲存記錄的資料；如伺服器沒有使用URL請求，響應應為201（建立），幷包含描述請求狀態和參考新資源的實體與位置頭。支援現場演示記錄的媒體伺服器必須支援時鐘範圍格式，smpte格式沒有意義");

       } elseif (request.getMethod().equals(RtspMethods.REDIRECT)) {

LOGGER.info("REDIRECT,流向：S-->C;引數要求：可選；功能：重定向請求通知客戶端連線到另一伺服器地址。它包含強制頭地址，指示客戶端釋出URL請求；也可能包括引數範圍，以指明重定向何時生效。若客戶端要繼續傳送或接收URL媒體，客戶端必須對當前連線傳送TEARDOWN請求，而對指定主執新連線傳送SETUP請求");

       } elseif (request.getMethod().equals(RtspMethods.SET_PARAMETER)) {

LOGGER.info("SET_PARAMETER,流向：C<-->S;引數要求：可選；功能：這個方法請求設定演示或URL指定流的引數值。請求僅應包含單個引數，允許客戶端決定某個特殊請求為何失敗。如請求包含多個引數，所有引數可成功設定，伺服器必須只對該請求起作用。伺服器必須允許引數可重複設定成同一值，但不讓改變引數值。注意：媒體流傳輸引數必須用SETUP命令設定。將設定傳輸引數限制為SETUP有利於防火牆。將引數劃分成規則排列形式，結果有更多有意義的錯誤指示");

       } elseif (request.getMethod().equals(RtspMethods.SETUP)) {

LOGGER.info("SETUP,流向：C-->S;引數要求：要求；功能：對URL的SETUP請求指定用於流媒體的傳輸機制。客戶端對正播放的流釋出一個SETUP請求，以改變伺服器允許的傳輸引數。如不允許這樣做，響應錯誤為“455 Method Not Valid In This State”。為了透過防火牆，客戶端必須指明傳輸引數，即使對這些引數沒有影響");

       } elseif (request.getMethod().equals(RtspMethods.TEARDOWN)) {

LOGGER.info("TEARDOWN,流向：C-->S;引數要求：要求；功能：TEARDOWN請求停止給定URL流傳送，釋放相關資源。如URL是此演示URL，任何RTSP連線標識不再有效。除非全部傳輸引數是連線描述定義的，SETUP請求必須在連線可再次播放前釋出");

       }

//  HttpResponse response = new DefaultRtspResponse(RtspVersion.RTSP_1_0, RtspResponseStatuses.OK);

//  response.setHeader(RtspHeaders.Names.CONNECTION, RtspHeaders.Values.KEEP_ALIVE);

//  response.setHeader(RtspHeaders.Names.CONTENT_LENGTH, cbuffer.array().length);

//  response.setProtocolVersion(RtspVersions.RTSP_1_0);

//  response.setStatus(RtspResponseStatuses.OK);

//  response.setHeader(RtspHeaders.Names.CSEQ, 5);

//  response.setChunked(true);

//  if(request.getMethod().getName().equals("GET")){

//     shanglenidexindewodexinhaoshangxin.mp3

       FileInputStream in = new FileInputStream("E://shanglenidexindewodexinhaoshangxin.mp3");

       FileChannel fchannel = in.getChannel();

long length = fchannel.size();

       MappedByteBuffer buffer = fchannel.map(FileChannel.MapMode.READ_ONLY, 0, length);

//     ChannelBuffer cbuffer = new DynamicChannelBuffer(8192);//8KB

       cbuffer.writeBytes(buffer);

//     cbuffer.writeBytes(in, 65536);

       response.setHeader(RtspHeaders.Names.CONTENT_LENGTH, cbuffer.array().length);

//     response.setChunked(true);

       response.setContent(cbuffer);

//  StreamSource ss = new StreamSource(new File("E://shanglenidexindewodexinhaoshangxin.mp3"));

//  FileInputStream in = new FileInputStream("E://shanglenidexindewodexinhaoshangxin.mp3");

//  ChunkedStream cs = new ChunkedStream(in);

//  response.setHeader(RtspHeaders.Names.CONTENT_TYPE, ChannelBuffer.class);

//  response.setHeader(RtspHeaders.Names.CONTENT_LENGTH,in.available());

//  response.setHeader(RtspHeaders.Names.RTP_INFO, cs);

//  }

    channel.write(response);

//  channel.write(cs);

//  channel.write(cbuffer);

}

@Override

publicvoid exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e)

throws Exception {

super

相關推薦