Socket 基礎解析使用ServerSocket建立聊天服務器

很簡單的教程哦！

 

1.socket 簡介

Socket 又稱"套接字"，應用程序通常通過"套接字"向網絡發出請求或者應答網絡請求。ServerSocket 用於服務器端，Socket 是建立網絡連接時使用的。在連接成功時，應用程序兩端都會產生一個 Socket 實例，操作這個實例，完成所需的會話。

 

2.ServerSocket 的建立與使用

最簡單的建立服務器ServerSocket

 

public class MyServerSocket {
    
    public static void main(String[] args) {
        try {
            //1-65535 監聽12345端口
            ServerSocket serverSocket = new ServerSocket(12345);
            //監聽客戶端鏈接，調用accept()方法 accept方法是一個阻塞的方法，會阻塞當前線程
            Socket socket = serverSocket.accept();
            //客戶端有請求時，彈出提示框
            JOptionPane.showMessageDialog(null, "有客戶鏈接到了本機的12345端口");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

 

運行該代碼，會發現程序阻塞在serverSocket.accept()處，打開瀏覽器請求127.0.0.1:12345  會有彈窗，程序結束

 

 

 

 

3.使用 ServerSocket 建立聊天服務器-1

 

上述方法是不合理的，因為accept()方法會造成程序阻塞，這樣，主線程就會被阻塞，對於阻塞的代碼，需要放置到獨立線程中，修改如下

 

public class MyServerSocket {
    public static void main(String[] args) {
        new ServerListener().start();
    }
}

 

監聽鏈接的線程

/**
 * 監聽連接的線程
 */
public class ServerListener extends Thread{
    @Override
    public void run() {
        try {
            //1-65535 監聽12345端口
            ServerSocket serverSocket = new ServerSocket(12345);
            //監聽客戶端鏈接，調用accept()方法 accept方法是一個阻塞的方法，會阻塞當前線程
            
            //每當有一個客戶端連接到當前的serversocket就會返回一個新的socket對象，所以當有多個的時候
            //就要創建一個while循環來監聽來自客戶端的鏈接
            while (true) {//true，讓他一直處於循環，不會結束
                Socket socket = serverSocket.accept();
                //客戶端有請求時，彈出提示框
                JOptionPane.showMessageDialog(null, "有客戶鏈接到了本機的12345端口");
                //由於每個socket又要與獨立的客戶端進行通訊，所以將socket傳遞給新的線程
                new ChatSocket(socket).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

用於通訊的線程

/**
 * 創建用於socket通信的線程
 */
public class ChatSocket extends Thread {
    
    Socket socket;//本地需要有socket來接受傳入的s值
    
    public ChatSocket(Socket s){
        this.socket=s;
    }
    
    public void out(String out){
        try {
            // 執行數據的輸出和相關功能的包裝
            socket.getOutputStream().write(out.getBytes("UTF-8"));
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    @Override
    public void run() {
        int count = 0;
        while (true) {
            count++;
            out("loop:"+count);
            try {
                sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

此時一個線程版的socket通信就算結束了，打開cmd 輸入telnet localhost 12345會有驚喜哦

這種驚喜（'telnet' 不是內部或外部命令，也不是可運行的程序）的自行百度

此時可以同時打開多個cmd 效果相同

 

 

 

4.使用 ServerSocket 建立聊天服務器-2

 

以上是一個簡單的socket聊天服務器，但是當前的服務器只有向客戶端發送數據的功能，並沒有從客戶端讀取數據的功能！

每個ChatSocket線程都是獨立的，不能相互共同數據，建立ChatManager溝通所有數據，代碼修改如下：

 

public class MyServerSocket {
    public static void main(String[] args) {
        new ServerListener().start();
    }
}

 

監聽鏈接的線程

/**
 * 監聽連接的線程
 */
public class ServerListener extends Thread{
    @Override
    public void run() {
        try {
            //1-65535 監聽12345端口
            ServerSocket serverSocket = new ServerSocket(12345);
            //監聽客戶端鏈接，調用accept()方法 accept方法是一個阻塞的方法，會阻塞當前線程
            
            //每當有一個客戶端連接到當前的serversocket就會返回一個新的socket對象，所以當有多個的時候
            //就要創建一個while循環來監聽來自客戶端的鏈接
            while (true) {//true，讓他一直處於循環，不會結束
                Socket socket = serverSocket.accept();
                //客戶端有請求時，彈出提示框
                JOptionPane.showMessageDialog(null, "有客戶鏈接到了本機的12345端口");
                //由於每個socket又要與獨立的客戶端進行通訊，所以將socket傳遞給新的線程
                ChatSocket cs = new ChatSocket(socket);
                cs.start();
                ChatManager.getChatManager().add(cs);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

創建用於socket通信的線程

/**
 * 創建用於socket通信的線程
 */
public class ChatSocket extends Thread {
    
    Socket socket;//本地需要有socket來接受傳入的s值
    
    public ChatSocket(Socket s){
        this.socket=s;
    }
    
    public void out(String out){
        try {
            // 執行數據的輸出和相關功能的包裝
            socket.getOutputStream().write(out.getBytes("UTF-8"));
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    @Override
    public void run() {//run方法中加入接收數據的功能
        try {
            BufferedReader br = new BufferedReader(
                    new InputStreamReader(
                            socket.getInputStream(),"UTF-8"));
            String line = null;
            while ((line = br.readLine())!=null) {//客戶端的數據
                //發給聊天室的所有人
                ChatManager.getChatManager().publish(this, line);
            }
            br.close();
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

聊天管理類

/**
 * 聊天管理類
 */
public class ChatManager {

    //單例化該ChatManager
    private ChatManager(){}
    private static final ChatManager cm = new ChatManager();
    public static ChatManager getChatManager(){
        return cm;
    }
    Vector<ChatSocket> vector = new Vector<ChatSocket>();
    
    public void add(ChatSocket cs){
        vector.add(cs);
    }
    
    public void publish(ChatSocket cs,String out){
        for(int i=0;i<vector.size();i++){
            ChatSocket cschatSocket = vector.get(i);
            if(!cs.equals(cschatSocket)){//發送消息的對象不接受消息本身
                cschatSocket.out(out);
            }
        }
    }
}

 

 

打開多個cmd，實現聊天功能，無論在哪個終端發，都能接收到消息