WEB服務(wù)器啟動(dòng)時(shí)加載一個(gè)ServerSocket服務(wù)

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

2、置，具體如下：Test/servlet-nameservicetv/senvlet-class3這樣做有一個(gè)很人的問(wèn)題，就是服務(wù)器關(guān)閉時(shí)資源無(wú)法得到完全釋放，端11可能仍然被占用編寫(xiě)監(jiān)聽(tīng)器Listener中配置的類(lèi)ServerSocketListener類(lèi)需要實(shí)現(xiàn)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上下文初始化時(shí)啟動(dòng)socket服務(wù)端線(xiàn)程*門(mén)定義一個(gè)Socket線(xiàn)程類(lèi)繼承門(mén)線(xiàn)程類(lèi)，重寫(xiě)run()方法，用丁接收客戶(hù)端socket請(qǐng)求報(bào)文*/classSocketThreadextendsThreadprivateServletContextservletContext;privateServersocketserversocket;publicSocketThread(ServerSocketserverSocketServletContextservletContext)this.servletContext=servletContext;/從web.xml中con

5、text-param節(jié)點(diǎn)獲取socket端口Stringport=this.senvletContextgetlnitParameter(socketPort);if(serversocket=null)trythis.serverSocket=newServerSocket(Integer);catch(IOExceptione)epnintStackTrace();publicvoidrun()while(!this.islnterrupted()/線(xiàn)程未中斷執(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消息報(bào)文處理類(lèi)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();/從流中讀取請(qǐng)求消息報(bào)文/執(zhí)行自定義的請(qǐng)求解析方法，生成響應(yīng)responsepw.printIn(response);pw.flush();/刷新緩沖區(qū)catch(IOExceptione)e.printStackTrace();個(gè)簡(jiǎn)單的Socket客戶(hù)端，用于驗(yàn)證以上程序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