使用tcp工具调试socket服务端通信 |
您所在的位置：网站首页 › tcpip工具app › 使用tcp工具调试socket服务端通信 |
使用tcp工具调试socket服务端通信
|
背景介绍： 客户端是用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(); } } }服务线程： 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("🥛"); ret += bytesToHexString(bytes) + " "; if (inputStream.available() == 0) { //一个请求 System.out.print("🍓"); System.out.println(socket.getRemoteSocketAddress() + ":" + ret + " 当前线程：" + this.getName() + "，状态：" + this.getState() + " 线程活跃数量：" + Thread.activeCount() + ",设备编码：" + Arrays.toString(hardCode)); ret = ""; } System.out.print("🍌"); } System.out.println("出for循环"); } catch (IOException e) { System.out.println("socket强制关闭了！！"); } finally { //关闭资源 try { if (socket != null) { socket.close(); } } catch (IOException e) { e.printStackTrace(); } System.out.println(getName() + "执行完成"); } } /** * 将16进制字符转换成byte[]数组。与byte2Hex功能相反。 * * @param string 16进制字符串 * @return byte[]数组 */ public static byte[] hex2Byte(String string) { if (string == null || string.length() // 截取没两个字符的前一个，将其转为int数值 int high = Integer.parseInt(string.substring(i * 2, i * 2 + 1), 16); // 截取没两个字符的后一个，将其转为int数值 int low = Integer.parseInt(string.substring(i * 2 + 1, i * 2 + 2), 16); // 高位字符对应的int值*16+低位的int值，强转成byte数值即可 // 如dd，高位13*16+低位13=221(强转成byte二进制11011101，对应十进制-35) bytes[i] = (byte) (high * 16 + low); } return bytes; } /** * byte[]数组转换为16进制的字符串 * * @param bytes 要转换的字节数组 * @return 转换后的结果 */ public static String bytesToHexString(byte[] bytes) { StringBuilder sb = new StringBuilder(); for (int i = 0; i sb.append('0'); } sb.append(hex); } return sb.toString(); } }断电重连单例缓存： package cn.socketTest; import java.util.HashMap; import java.util.Map; //缓存 存放 编码对应的线程 public class StoreMap { private StoreMap(){ } private static Map instance = new HashMap(); public static Map getInstance() { return instance; } public static void setInstance(Map instance) { StoreMap.instance = instance; } }程序刚开始是参考网络上的代码，参考代码能够做到用tcp连接到服务端，并没有断网重连的处理，逻辑是每次收到客户端连接创建一个线程服务，将该客户端和对应的线程存到map中，每次创建新线程时，先去map里查询该客户端有没有连过，如果能查到到，将这个查到的线程杀死，然后将该设备标识和新创建的线程再存到map中，然后再进行接受数据，处理业务。 断网重连的难点是，杀死线程，折腾两天才弄好，普通没有socket情况下，将while循环中的exit置为true，线程就能停止，该程序因为涉及到socket，不仅exit要置为true，还需要关闭socket才能线程才能结束。如果不关闭socket，他会一直停在这行代码： while (!exit && inputStream.read(bytes) != -1) {不会往下走。 场景：在tcp工具开了三个客户端，模拟三个设备，数据前三位假设传的是设备编码，设备编码一样的是同一个客户端。 49设备是第一个连接服务端，当前活跃的线程数是2，包括一个main线程，一个服务49设备的服务端线程。50设备第二个连接服务端，然后50设备又关掉客户端，线程数由3个变成2个，再次开启50设备，当前线程数又变成了3个。51设备第三个链接服务端，连接成功后，服务端断网，客户端继续发送消息，服务端无响应，请求超时，客户端单方面断开 连接，请注意是单方面，因为服务端对应的线程还活着，假设取名51老线程。该设备再次访问服务端时，需要先连接，再发送数据，服务端会创建一个新线程服务51设备，假设取名51新线程，到现在为止，是有俩线程为该设备服务，51老线程会一直在while那行代码等待数据，但是一直会等不到，因为51新线程在服务51设备。所以当前所写的程序是杀死51老线程。杀死之后线程数又是4个。后台打印： 参考博文： https://blog.csdn.net/weixin_28706423/article/details/115235972 https://blog.csdn.net/sdwujk160507140150/article/details/113939781 |
【本文地址】
今日新闻 |
推荐新闻 |