java的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方法

    }

}

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

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