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

2024-06-11 15:12:04
开发
23

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

---同行者联盟

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();
    }
}

结果：

客户端结果截图：

服务端结果截图：

注意：

针对大学生的辅导班和准大学生的提前学

1) 对于面试而言，最重要的是算法和项目，现特邀P8大佬，哈工程研究生毕业者授数据结构与算法，带领大家学习300道经典算法题；

2) 项目课开始启动，带领大家领略企业中的项目流程

3) 暑假学习包括但不限于mysql、Java体系(语言、框架、javaWeb等)、C++、C语言、python语言、数据结构与算法、linux、redis；

4) 大数据的学习

有意向的可以沟通+V 17865578823

原文地址:https://blog.csdn.net/qq_40967969/article/details/139594960 本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：https://www.suanlizi.com/kf/1800425752471146496.html 如若内容造成侵权/违法违规/事实不符，请联系《酸梨子》网邮箱：1419361763@qq.com进行投诉反馈，一经查实，立即删除！

阅读全部