日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

上一篇文章說到怎樣寫一個最簡單的Java Socket通信，但是在上一篇文章中的例子有一個問題就是Server只能接受一個Client請求，當?shù)谝粋€Client連接后就占據(jù)了這個位置，后續(xù)Client不能再繼續(xù)連接，所以需要做些改動，當Server沒接受到一個Client連接請求之后，都把處理流程放到一個獨立的線程里去運行，然后等待下一個Client連接請求，這樣就不會阻塞Server端接收請求了。每個獨立運行的程序在使用完Socket對象之后要將其關閉。

成都創(chuàng)新互聯(lián)公司專注于榆中網(wǎng)站建設服務及定制，我們擁有豐富的企業(yè)做網(wǎng)站經驗。 熱誠為您提供榆中營銷型網(wǎng)站建設，榆中網(wǎng)站制作、榆中網(wǎng)頁設計、榆中網(wǎng)站官網(wǎng)定制、小程序定制開發(fā)服務，打造榆中網(wǎng)絡公司原創(chuàng)品牌,更為您提供榆中網(wǎng)站排名全網(wǎng)營銷落地服務。

具體代碼如下：

 
 
 

  
  
  
package com.googlecode.garbagecan.test.socket.sample2; 
  
  
  

  
  
  
import java.io.BufferedReader; 
  
  
  
import java.io.IOException; 
  
  
  
import java.io.InputStreamReader; 
  
  
  
import java.io.PrintWriter; 
  
  
  
import java.net.ServerSocket; 
  
  
  
import java.net.Socket; 
  
  
  

  
  
  
public class MyServer { 
  
  
  
    public static void main(String[] args) throws IOException { 
  
  
  
        ServerSocket server = new ServerSocket(10000); 
  
  
  
         
  
  
  
        while (true) { 
  
  
  
            Socket socket = server.accept(); 
  
  
  
            invoke(socket); 
  
  
  
        } 
  
  
  
    } 
  
  
  
     
  
  
  
    private static void invoke(final Socket client) throws IOException { 
  
  
  
        new Thread(new Runnable() { 
  
  
  
            public void run() { 
  
  
  
                BufferedReader in = null; 
  
  
  
                PrintWriter out = null; 
  
  
  
                try { 
  
  
  
                    in = new BufferedReader(new InputStreamReader(client.getInputStream())); 
  
  
  
                    out = new PrintWriter(client.getOutputStream()); 
  
  
  

  
  
  
                    while (true) { 
  
  
  
                        String msg = in.readLine(); 
  
  
  
                        System.out.println(msg); 
  
  
  
                        out.println("Server received " + msg); 
  
  
  
                        out.flush(); 
  
  
  
                        if (msg.equals("bye")) { 
  
  
  
                            break; 
  
  
  
                        } 
  
  
  
                    } 
  
  
  
                } catch(IOException ex) { 
  
  
  
                    ex.printStackTrace(); 
  
  
  
                } finally { 
  
  
  
                    try { 
  
  
  
                        in.close(); 
  
  
  
                    } catch (Exception e) {} 
  
  
  
                    try { 
  
  
  
                        out.close(); 
  
  
  
                    } catch (Exception e) {} 
  
  
  
                    try { 
  
  
  
                        client.close(); 
  
  
  
                    } catch (Exception e) {} 
  
  
  
                } 
  
  
  
            } 
  
  
  
        }).start(); 
  
  
  
    } 
  
  
  
}
 
 
 

下面是Client程序代碼：

 
 
 

  
  
  
package com.googlecode.garbagecan.test.socket.sample2; 
  
  
  

  
  
  
import java.io.BufferedReader; 
  
  
  
import java.io.InputStreamReader; 
  
  
  
import java.io.PrintWriter; 
  
  
  
import java.net.Socket; 
  
  
  

  
  
  
public class MyClient { 
  
  
  
    public static void main(String[] args) throws Exception { 
  
  
  
        Socket socket = new Socket("localhost", 10000); 
  
  
  
        BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); 
  
  
  
        PrintWriter out = new PrintWriter(socket.getOutputStream()); 
  
  
  
        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); 
  
  
  

  
  
  
        while (true) { 
  
  
  
            String msg = reader.readLine(); 
  
  
  
            out.println(msg); 
  
  
  
            out.flush(); 
  
  
  
            if (msg.equals("bye")) { 
  
  
  
                break; 
  
  
  
            } 
  
  
  
            System.out.println(in.readLine()); 
  
  
  
        } 
  
  
  
        socket.close(); 
  
  
  
    } 
  
  
  
} 
 
 
 

測試，首先運行MyServer類，然后運行兩個MyClient類，然后分別在每個MyClient的提示符下輸入字符串，就可以看到Server可以分別接收處理每個Client的請求了。

當前標題：JavaSocket實戰(zhàn)之二：多線程通信
文章鏈接：http://www.5511xx.com/article/dhcecse.html