使用tcp工具调试socket服务端通信_tcp在线调试

背景介绍：
客户端是用tcp连接调试，工具链接: https://pan.baidu.com/s/1kfjv1jdS8KJgb7YVSu9Wtw 提取码: z34a
服务端是Java代码写的逻辑，用byte[]流接收客户端传来的数据，再转化成16进制字符串

目前服务端程序功能：

• 接收客户端tcp工具通信
• 用byte[]流接收客户端传来的数据，再转化成16进制字符串
• 解决客户端/服务端断网重连问题

先贴代码，服务端启动类

package cn.socketTest;

import java.io.IOException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * 接收的是byte[]字节流，转化成16进制字符，每次接到一个新的客户端连接，对应创建一个线程
 *
 * 断电重连：该程序满足。
 *         场景：客户端/服务端没有网络，客户端发送消息，服务端没有回应，客户端请求超时，自动断开连接，当恢复网络时，客户端再次连接服务端，连接成功。这个时候服务端对应的该客户端
 *         有俩个线程，处理方式是杀死之前的旧线程，用新创建的线程服务该客户端
 *
 * 服务端断网：
 */

public class SocketServer {
    public static void main(String[] args) {
        try {
            ServerSocket serverSocket = new ServerSocket(1111);//创建绑定到特定端口的服务器Socket。
            Socket socket = null;//需要接收的客户端Socket
            System.out.println("服务器启动");
            //定义一个死循环，不停的接收客户端连接
            while (true) {
                socket = serverSocket.accept();//侦听并接受到此套接字的连接
                InetAddress inetAddress = socket.getInetAddress();//获取客户端的连接
                System.out.print("inetAddress : " + inetAddress);
                ServerThread thread = new ServerThread(socket, inetAddress);//自己创建的线程类
                thread.start();
                int count = Thread.activeCount() - 1;//当前线程数-主线程数就是活动的线程
                System.out.println("  客户端数量：" + count);//打印客户端数量
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

服务线程：

package cn.socketTest;

import java.io.IOException;
import java.io.InputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Arrays;

public class ServerThread extends Thread {

    InetAddress inetAddress = null;//接收客户端的连接
    private volatile Socket socket = null;

    private volatile boolean exit = false;

    private volatile InputStream inputStream = null;

    public ServerThread(Socket socket, InetAddress inetAddress) throws IOException {
        this.socket = socket;
        this.inetAddress = inetAddress;
        this.inputStream = socket.getInputStream();
    }

    @Override
    public void run() {
        try {
            //封装输入流（接收客户端的字节流）
            byte[] hardCode = new byte[3];//假设 前三位传参是机器编码，先取出机器编码
            byte[] bytes = new byte[1]; // 一次读取一个byte
            inputStream.read(hardCode);//读取硬件编码
            //断网重连
            ServerThread td = StoreMap.getInstance().get(Arrays.toString(hardCode));
            if (td != null) {
                td.exit = true;
                td.inputStream.close();
                td.socket.close();
            }
            StoreMap.getInstance().put(Arrays.toString(hardCode), this);//存当前线程

            String ret = "";
            while (!exit && inputStream.read(bytes) != -1) {
                System.out.print("
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/你好赵伟/article/detail/886237