socket系列（一）——socket实现推送

public classTestPush {
   
    @SuppressWarnings("resource")
    @Test
    public void pushService() throws IOException {
       ServerSocketserviceSocket= newServerSocket(10888);
       while(true) {
           Socketsocket= serviceSocket.accept();
           InputStreamclientMsgIs= socket.getInputStream();
           StringclientMsg= StreamUtil.inputStreamToString(clientMsgIs, "UTF-8");
           System.out.println(clientMsg);
           socket.shutdownInput();
          
           System.out.println("请输入推送信息：");
           Scannersc = new Scanner(System.in);
           StringpushMsg= sc.nextLine();
          
           OutputStreamserviceOs= socket.getOutputStream();
           BufferedWriterwriter= newBufferedWriter(newOutputStreamWriter(serviceOs));
           while(!"end".equals(pushMsg)) {
              writer.write(pushMsg);
              writer.newLine();
              writer.flush();
              System.out.println("请输入推送信息：");
              sc = new Scanner(System.in);
              pushMsg = sc.nextLine();
           }
           socket.shutdownOutput();
           serviceOs.close();
           socket.close();
       }
    }
   
    @SuppressWarnings("resource")
    @Test
    public void pushClient() throws UnknownHostException,IOException {
       Socketsocket= newSocket("127.0.0.1", 10888);
      
       OutputStreamos = socket.getOutputStream();
       Stringcmsg= "client connect success";
       os.write(cmsg.getBytes("UTF-8"));
       os.flush();                 //这是socket强制发送
       socket.shutdownOutput();
      
       InputStreamserviceMsgIs= socket.getInputStream();
       BufferedReaderreader= newBufferedReader(newInputStreamReader(serviceMsgIs));
       Stringcontent= null;
       while(true) {
           if((content = reader.readLine()) != null) {
               System.out.println(content); 
           }
       }
    }  
}