關于Socket監聽服務端口應用

Socket監聽服務端口應用，實時監聽，希望有大牛指出不足，上代碼....

伺服器啟動監聽類：

public class ListenerServer extends HttpServlet implements ServletContextListener { //MyServletContextListener是監聽者類
   public void contextDestroyed(ServletContextEvent arg0) {
   
   }
   public void contextInitialized(ServletContextEvent arg0) {
      
      System.out.println("-----------------開始線程-------------------------");
      //守護線程
      System.out.println("-----------------Socket監聽已啟動--------------------------");
      StartThread s=new StartThread();
      s.setDaemon(true);// 設定線程為背景線程，tomcat不會被hold,啟動後依然一直監聽。
      s.start();
   }
}      

守護線程：

public class StartThread extends Thread {

   public void run() {
      System.out.println("-----------------觸發監聽:---------------------------");
      int port=8001;
      System.out.println("-----------------Tomcat port:"+port+"---------------------------");
      
      try {
         ServerSocket serverSocket = new ServerSocket(port);
// 輪流等待請求
         while(true)
         {
// 等待用戶端請求,無請求則閑置;有請求到來時,傳回一個對該請求的socket連接配接
            Socket clientSocket = serverSocket.accept();
            //2、調用accept()方法開始監聽，等待用戶端的連接配接
            // 使用accept()阻塞等待客戶請求，有客戶
            //請求到來則産生一個Socket對象，并繼續執行
// 建立zithread對象,通過socket連接配接通信
            Thread t = new Thread(new zithread(clientSocket));
            t.start();
         }
         
      } catch (IOException e) {

// TODO Auto-generated catch block
         
         e.printStackTrace();
         
      }
      
   }
   
}      

守護線程子線程：

public class zithread implements Runnable{
   
   private BufferedReader reader;
   
   private Socket socket;
   
   public zithread(Socket clientSocket)
   {
      System.out.println("-----------------觸發監聽:---------------------------");
      try
      {
         // 得到socket連接配接
         socket = clientSocket;
         // 得到用戶端發來的消息 轉成輸入流
         //擷取輸入流，并讀取用戶端資訊
         InputStreamReader isReader = new InputStreamReader(socket.getInputStream());//字元流
         
         reader = new BufferedReader(isReader);//緩沖方式文本讀取由Socket對象得到輸入流，并構造相應的BufferedReader對象

         //發送指令 輸出流
         
         /*OutputStream os=socket.getOutputStream();
         
         PrintWriter pw=new PrintWriter(os);
         
         String info=" hello  kitty ";
         
         pw.write(info);
         
         pw.flush();*/

         //=socket.shutdownOutput();
      
      } catch (IOException e)
      
      {
         
         e.printStackTrace();
         
      }
      
   }
   /*監聽端口資料處理*/
   public void run() {
      String message;
      try
      {
   
         
         while((message = reader.readLine()) != null)//readLine 方法讀資料
         
         {

            System.out.println("用戶端消息: " + message.getBytes());
            

         }
         
      } catch (IOException e)
      
      {
         
         e.printStackTrace();
         
      }
      
   }
   
}      

<listener>
  <listener-class>com.xx.xx.xx.ListenerServer</listener-class>
</listener>
      

注意端口設定