java的socket连接，聊天室通信实现

Posted 2021-08-09 诗一样的代码

很多小伙伴在读大学的时候都分不清客户端和服务器的区别。简单来说，没有联网功能的程序，都是在玩单机。那么一个程序要怎么才能联网呢？接下来我们来聊聊socket连接。

认识socket

Socket是应用层与TCP/IP协议族通信的中间软件抽象层，它是一组接口。在设计模式中，Socket其实就是一个门面模式，它把复杂的TCP/IP协议族隐藏在Socket接口后面，对用户来说，一组简单的接口就是全部，让Socket去组织数据，以符合指定的协议。

上面就是原理图。

服务端

/** 
 * 模拟qq聊天功能： 实现客户端与服务器（一对一）的聊天功能，客户端首先发起聊天，输入的内容在服务器端和客户端显示， 
 * 然后服务器端也可以输入信息，同样信息也在客户端和服务器端显示 
 */  

// 服务器类  
public class server {//ChatServer类  
    private int port = 8081;// 默认服务器端口  

    public server() {

    }  

    // 创建指定端口的服务器  
    public server(int port) {//构造方法  
        this.port = port;//将方法参数赋值给类参数  
    }  

    // 提供服务  
    public void service() {//创建service方法  
        try {// 建立服务器连接  
            ServerSocket server = new ServerSocket(port);//创建  ServerSocket类             
            Socket socket = server.accept();// 等待客户连接  
            try {                  
                DataInputStream in = new DataInputStream(socket  
                        .getInputStream());// 读取客户端传过来信息的DataInputStream                   
                DataOutputStream out = new DataOutputStream(socket  
                        .getOutputStream());// 向客户端发送信息的DataOutputStream                     
                Scanner scanner = new Scanner(System.in);//从键盘接受数据  
                while (true) {                       
                         ...完整源码，公众号：诗一样的代码
                }  
            } finally {// 建立连接失败的话不会执行socket.close();
                socket.close();//关闭连接 
                server.close();//关闭                
            }  
        } catch (IOException e) {//捕获异常
            e.printStackTrace();  
        }  
    }  

    public static void main(String[] args) {//主程序方法  
        new server().service();//调用 service方法 
    }  
}  

客户端

public class client {//创建公共类
    private String host = "localhost";// 默认连接到本机
    private int port = 8081;// 默认连接到端口8189

    public client() {

    }

    // 连接到指定的主机和端口
    public client(String host, int port) {//构造方法
        this.host = host;//将构造方法的参数host传递给类变量host
        this.port = port;//将构造方法的参数port传递给类变量port
    }

    public void chat() {//chat方法
        try {
            // 连接到服务器
            Socket socket = new Socket(host, port);//创建Socket类对象

            try {

                DataInputStream in = new DataInputStream(socket
                        .getInputStream());// 读取服务器端传过来信息的DataInputStream

                DataOutputStream out = new DataOutputStream(socket
                        .getOutputStream());// 向服务器端发送信息的DataOutputStream


                Scanner scanner = new Scanner(System.in);// 装饰标准输入流，用于从控制台输入

                while (true) {
                    ...完整源码，公众号：诗一样的代码
                }

            } finally {
                socket.close();//关闭Socket监听
            }
        } catch (IOException e) {//捕获异常
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {//主程序方法
        new client().chat();//调用chat方法
    }
}

最后代码直接运行就能得到想要的通信。这里要注意的是：服务器需要先开，不然客户端会连接失败。

我们只需要配合上面的流程图，加上具体的源码就可以实现客户端与服务器端通信。有需要拿完整源码的话，请移步到公众号：诗一样的代码。既然进来了，小伙伴点个赞再走呗。