大一学生分享网络编程聊天室-简单私聊

每天过得充实，你将不会焦虑

---同行者联盟

Socket

是一种规范(标准)，封装了TCP协议的通信细节，使得我们使用它就可以完成与远端计算机的TCP链接，以及数据的传输。并且可以完成数据传输基于双向流的读写操作，Java语言里封装了Socket类，直接使用即可

客户端给服务端发送消息（写），服务端读到信息 (读) 以后发响应给客户端（写），客户端接收响应信息（读），所以客户端和服务端都具有读+写能力

做一个类似于聊天室的功能，分为以下3个步骤

1、客户端连接服务端

2、客户端成功给服务端发送消息，服务端接收消息

3、客户端给服务端发送消息，服务端接收消息后给出响应，客户端接收响应 (一人一句)

1、客户端连接服务端

客户端代码

public class SocketClient {
    public static void main(String[] args) throws IOException {
        System.out.println("开始连接");
        // 创建网络连接对象，并指定访问地址+端口号，端口号不要乱指定，建议大家使用80系列
        Socket socket = new Socket("localhost",8088);
        System.out.println("连接成功！！！");
    }
}

服务端代码

public class SocketServer {
    public static void main(String[] args) throws IOException {
        // 创建服务端对象，确定好接收的端口信息
        ServerSocket  serverSocket = new ServerSocket(8088);
        System.out.println("等待客户端连接");
        // 舰艇有没有客户端发请求给8088端口号,accept是阻塞方法，一直会监听客户端的连接,直到才客户端连接上为止
        Socket socket = serverSocket.accept();
        System.out.println("客户端已连接！！！");
    }
}

注意⚠️：

运行时必须先运行服务端，举例说明，小明(客户端)给小红（服务端）打电话，但是前提必须是小红得有手机号，所以第一步是小红先申请电话号，第二步是小明打电话给小红，对应我们的代码是服务端先申请端口号，客户端才能给该host的端口发送连接请求

2、客户端给服务端发送消息，服务端能成功接收

客户端代码：

import java.io.*;
import java.net.Socket;
import java.util.Scanner;
public class SocketClient {
    Socket socket;
    public SocketClient() {
        System.out.println("开始连接");
        // 创建网络连接对象，并指定访问地址+端口号，端口号不要乱指定，建议大家使用80系列，8080最容易被占用
        try {
            socket = new Socket("localhost", 8088);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public void start(){
        try {
            System.out.println("客户端已启动");
            OutputStream outputStream = socket.getOutputStream();
            OutputStreamWriter outputStreamWriter = new OutputStreamWriter(outputStream,"utf-8");
            BufferedWriter bufferedWriter = new BufferedWriter(outputStreamWriter);
            // 自动行刷新，即不会将缓冲区装满，按行刷新写数据
            PrintWriter printWriter = new PrintWriter(bufferedWriter,true);
            Scanner sc = new Scanner(System.in);
            while(true){
                String message = sc.nextLine();
                printWriter.println(message);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
          //  关流
        }
    }
    public static void main(String[] args) {
        SocketClient client = new SocketClient();
        client.start();
    }
}

服务端代码：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class SocketServer {
    ServerSocket serverSocket;
    public SocketServer() {
        // 创建服务端对象，确定好申请的端口号
        try {
            serverSocket = new ServerSocket(8088);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public void start() {
        System.out.println("服务端已启动");
        System.out.println("等待客户端连接");
        try {
            Socket socket = serverSocket.accept();
            System.out.println("客户端已连接！！！");
            // 从获取的客户端对象中，获取数据，前提是获取IO流
            InputStream inputStream = socket.getInputStream();
            // 转化为字符流
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
            //为了更高效，我们可以加上缓冲流,而且BufferReader还可以按行读
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
            String line = null;
            while ((line = bufferedReader.readLine())!=null) {
                System.out.println("客户端发来消息："+line);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
          //  关流
        }
    }
    public static void main(String[] args) {
        SocketServer socketServer = new SocketServer();
        System.out.println("端口好已成功申请");
        socketServer.start();
    }
}

结果：

3、客户端与服务端正常交流（一人一句）

客户端代码

import java.io.*;
import java.net.Socket;
import java.util.Scanner;
public class SocketClient {
    Socket socket;
    public SocketClient() {
        System.out.println("开始连接");
        // 创建网络连接对象，并指定访问地址+端口号，端口号不要乱指定，建议大家使用80系列，8080最容易被占用
        try {
            socket = new Socket("localhost", 8088);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public void start(){
        try {
            System.out.println("客户端已启动");
            OutputStream outputStream = socket.getOutputStream();
            OutputStreamWriter outputStreamWriter = new OutputStreamWriter(outputStream,"utf-8");
            BufferedWriter bufferedWriter = new BufferedWriter(outputStreamWriter);
            // 自动行刷新，即不会将缓冲区装满，按行刷新写数据
            PrintWriter printWriter = new PrintWriter(bufferedWriter,true);
            Scanner sc = new Scanner(System.in);
            // 从获取的客户端对象中，获取数据，前提是获取IO流
            InputStream inputStream = socket.getInputStream();
            // 转化为字符流
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
            //为了更高效，我们可以加上缓冲流,而且BufferReader还可以按行读
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
            String line = null;
            while(true){
                String message = sc.nextLine();
                printWriter.println(message);
                line = bufferedReader.readLine();
                if(line!=null){
                    System.out.println("服务端发来消息："+line);
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
          //  关流
        }
    }
    public static void main(String[] args) {
        SocketClient client = new SocketClient();
        client.start();
    }
}

服务端代码

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class SocketServer {
    ServerSocket serverSocket;
    public SocketServer() {
        // 创建服务端对象，确定好申请的端口号
        try {
            serverSocket = new ServerSocket(8088);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public void start() {
        System.out.println("服务端已启动");
        System.out.println("等待客户端连接");
        try {
            Socket socket = serverSocket.accept();
            System.out.println("客户端已连接！！！");
            // 从获取的客户端对象中，获取数据，前提是获取IO流
            InputStream inputStream = socket.getInputStream();
            // 转化为字符流
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
            //为了更高效，我们可以加上缓冲流,而且BufferReader还可以按行读
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
            OutputStream outputStream = socket.getOutputStream();
            OutputStreamWriter outputStreamWriter = new OutputStreamWriter(outputStream,"utf-8");
            BufferedWriter bufferedWriter = new BufferedWriter(outputStreamWriter);
            // 自动行刷新，即不会将缓冲区装满，按行刷新写数据
            PrintWriter printWriter = new PrintWriter(bufferedWriter,true);
            Scanner sc = new Scanner(System.in);
            String line = null;
            while ((line = bufferedReader.readLine())!=null) {
                System.out.println("客户端发来消息："+line);
                printWriter.println(sc.nextLine());
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
          //  关流
        }
    }
    public static void main(String[] args) {
        SocketServer socketServer = new SocketServer();
        System.out.println("端口好已成功申请");
        socketServer.start();
    }
}