WEB服務器啟動時加載一個ServerSocket服務

1、5riinfeiyaiig08Page Page WEB服務器啟動時加載一個ServerSocket服務如果在項目中需要讓一個SeiverSocket服務伴隨WEB服務器的啟動而啟動，時刻監(jiān)控某個端II,接收Socket客戶端發(fā)送過來的socket報文。需要做以卞配置，配置完成后程序支持隨服務器啟動，支持同時處理多個socket客戶端請求。配置web.xinl在web.xinl的節(jié)點中添加以下內容：socke七卩0廠七3800Socket服務隨web啟動而啟動serviceServerSocketListenecv/listener-class汩E：網上也有人提出可以使用sewlet節(jié)點進行配

2、置，具體如下：Test/servlet-nameservicetv/senvlet-class3這樣做有一個很人的問題，就是服務器關閉時資源無法得到完全釋放，端11可能仍然被占用編寫監(jiān)聽器Listener中配置的類ServerSocketListener類需要實現ServletContextListenerpublicclassServerSocketListenerimpleaentsServletContextListenerprivateSocketThreadsocketThread;publicvoidcontextDestroyed(ServletContextEvente)if(

3、socketThread!=null&socketThread.islnterrupted()socketThreadcloseServerSocket();socketThreadinterrupt();publicvoidcontextlnitialized(ServletContextEvente)ServletContextServletContext=e.getServletContext();if(str=null&socketThread=null)socketThread=newSocketThread(nullservletContext);socketThreadstart

4、();/servlet上下文初始化時啟動socket服務端線程*門定義一個Socket線程類繼承門線程類，重寫run()方法，用丁接收客戶端socket請求報文*/classSocketThreadextendsThreadprivateServletContextservletContext;privateServersocketserversocket;publicSocketThread(ServerSocketserverSocketServletContextservletContext)this.servletContext=servletContext;/從web.xml中con

5、text-param節(jié)點獲取socket端口Stringport=this.senvletContextgetlnitParameter(socketPort);if(serversocket=null)trythis.serverSocket=newServerSocket(Integer);catch(IOExceptione)epnintStackTrace();publicvoidrun()while(!this.islnterrupted()/線程未中斷執(zhí)行循環(huán)trySocketsocket=serversocketaccept();if(socket!=null)newProces

6、sSocketData(socket,this.servletContext).start();catch(IOExceptione)epnintStackTrace();publicvoidcloseServerSocket()if(serversocket!=null&!serversocketisClosed()serversocketclose();catch(IOExceptione)e.printStackTrace();Socket消息報文處理類classProcessSocketDataextendsThreadprivateSocketsocket;privateServle

7、tContextservletContext;publicProcessSocketData()super();publicProcessSocketData(Socketsocket,ServletContextservletContext)this.socket=socket;this.servletContext=servletContext;publicvoidrun()tryBufferedReaderbr=newBufferedReader(newInputStreamReader(socketgetlnputStream();Printwriterpw=newPrintwrite

8、r(socket.getOutputStream();Stringrequest=br.readLine();/從流中讀取請求消息報文/執(zhí)行自定義的請求解析方法，生成響應responsepw.printIn(response);pw.flush();/刷新緩沖區(qū)catch(IOExceptione)e.printStackTrace();個簡單的Socket客戶端，用于驗證以上程序publicclassTestclientpublicvoidcreateSocketClient(Stninghost,intport)Socketsocket=null;PrintWriterpw=null;BufferedReaderbr=null;tryStringrequest=M20110624u;socket=newSocket(host,port);pw=newPrintWriter(newOutputStreamV/riter(socket.getOutputStream();pw.println(requesti);pv/.flush();br=newBufferedReader(newInputStreamReader(socketgetlnputStream();System.outpnintln(brreadLine();c