中文字幕在线观看,亚洲а∨天堂久久精品9966,亚洲成a人片在线观看你懂的,亚洲av成人片无码网站,亚洲国产精品无码久久久五月天

Java Socket多線程編程示例

2018-07-20    來源:open-open

容器云強勢上線!快速搭建集群,上萬Linux鏡像隨意使用

客戶端代碼如下:

    import java.io.*;  
    import java.net.*;  
    import java.util.Scanner;  
      
    public class SimpleChatClient {  
        BufferedReader reader;  
        PrintWriter writer;  
        Socket sock;  
          
        public void go(){  
            System.out.println("客戶端啟動!");  
            setUpNetworking();  
            //發(fā)送數(shù)據(jù)到服務(wù)器  
            Scanner scanner=new Scanner(System.in);  
            String sendString=scanner.nextLine();  
            while(sendString!=null&&!sendString.equals("byebye")){  
                writer.println(sendString);  
                writer.flush();  
                sendString=scanner.nextLine();  
            }  
            scanner.close();  
            System.out.println("客戶端退出!");  
        }  
          
        public void setUpNetworking(){  
            try {  
                sock=new Socket("127.0.0.1",5000);  
                InputStreamReader streamReader=new InputStreamReader(sock.getInputStream());  
                reader=new BufferedReader(streamReader);  
                writer=new PrintWriter(sock.getOutputStream());  
                System.out.println("networking established");  
            } catch (IOException e) {  
                // TODO Auto-generated catch block  
                e.printStackTrace();  
            }  
        }  
              
          
        public static void main(String[] args) {  
            // TODO Auto-generated method stub  
            SimpleChatClient client=new SimpleChatClient();  
            client.go();  
        }  
      
    }  

服務(wù)器端代碼如下:
    import java.io.*;  
    import java.net.*;  
    public class SimpleChatServer {   
        //內(nèi)部類  
        public class ClientHandler implements Runnable{  
            BufferedReader reader;  
            Socket sock;  
          
            public ClientHandler(Socket clientSocket){  
                sock=clientSocket;  
                InputStreamReader isReader;  
                try {     
                    isReader = new InputStreamReader(sock.getInputStream());  
                    reader=new BufferedReader(isReader);  
                } catch (IOException e) {  
                    // TODO Auto-generated catch block  
                    e.printStackTrace();  
                }  
                  
            }     
            @Override  
            public void run() {  
                // TODO Auto-generated method stub  
                String messageString;  
                try {  
                    while((messageString=reader.readLine())!=null){  
                        System.out.println("read "+messageString);  
                    }  
                } catch (IOException e) {  
                    // TODO Auto-generated catch block            
                        System.out.println("有一個連接斷開");  
                }  
            }  
              
        }  
        public void go(){  
            System.out.println("服務(wù)器啟動成功!");  
            ServerSocket serverSock;  
            try {  
                serverSock = new ServerSocket(5000);  
                while(true){  
                    Socket clientSocket=serverSock.accept();  
                    Thread thread=new Thread(new ClientHandler(clientSocket));  
                    thread.start();  
                    System.out.println("got a connection!");  
                }  
            } catch (IOException e) {  
                // TODO Auto-generated catch block  
                e.printStackTrace();  
            }  
              
        }  
          
        public static void main(String[] args) {  
            // TODO Auto-generated method stub  
            new SimpleChatServer().go();  
        }  
      
    }  

標簽: 代碼 服務(wù)器 服務(wù)器端

版權(quán)申明:本站文章部分自網(wǎng)絡(luò),如有侵權(quán),請聯(lián)系:west999com@outlook.com
特別注意:本站所有轉(zhuǎn)載文章言論不代表本站觀點!
本站所提供的圖片等素材,版權(quán)歸原作者所有,如需使用,請與原作者聯(lián)系。

上一篇:Java執(zhí)行外部程序并返回結(jié)果

下一篇:一個簡單的java死鎖示例