最简单的一个socket服务端

Posted 2021-03-26 农名工进城

描述：这是一个socket服务端，可以用串口调试工具连接和发送数据过来，服务端启动，客户端可以不断的断开连接、断开连接，不会影响数据接受

package com.thinkgem.wlw.modules.lhjh.socket.tstandard;

import java.io.BufferedInputStream;
import java.io.DataInputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashMap;
import java.util.Map;

/**
 * socket 服务端
 *
 * @Author: zhouhe
 * @Date: 2019/4/12 11:08
 */
public class Server {

    private static class ClientHandler implements Runnable {

        private Socket socket;

        public ClientHandler(Socket socket) {
            this.socket = socket;
        }

        @Override
        public void run() {
            try {
                //封装输入流（接收客户端的流）
                BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
                DataInputStream dis = new DataInputStream(bis);

                byte[] bytes = new byte[1]; // 一次读取一个byte

                String ret = "";
                while (dis.read(bytes) != -1) {
                    ret += bytesToHexString(bytes) + "";
                    if (dis.available() == 0) { //一个请求

                        //todo 下面打印部分在项目部署的时候要去掉
                     /*   System.out.println(socket.getRemoteSocketAddress() + ":" + ret);
                        System.out.println();
                        System.out.println("转换为字符串后:"+hexStringToString(ret));
                        System.out.println();
                        System.out.println("转为map后的数据："+aToMap(hexStringToString(ret)));
                        System.out.println();*/

//                        Thread.sleep(3000);

//                        MessageParsing.explain(hexStringToString(ret)); //报文解析

                        System.out.println("转换为字符串后:"+hexStringToString(ret));
                        ret = "";
                    }
                }
            } catch (Exception e) {

            } finally {
                System.out.println("client is over");
                if (socket != null) {
                    try {
                        socket.close();
                    } catch (IOException e) {

                    }
                }
            }
        }
    }

    /**
     * byte[]数组转换为16进制的字符串
     *
     * @param bytes 要转换的字节数组
     * @return 转换后的结果
     */
    public static String bytesToHexString(byte[] bytes) {
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < bytes.length; i++) {
            String hex = Integer.toHexString(0xFF & bytes[i]);
            if (hex.length() == 1) {
                sb.append(\'0\');
            }
            sb.append(hex);
        }
        return sb.toString();
    }

    /**
     * 16进制转换成为string类型字符串
     * 这个方法中文会乱码，字母和数字都不会乱码
     *
     * @Author zhouhe
     * @param s
     * @return
     */
    public static String hexStringToString(String s) {
        if (s == null || s.equals("")) {
            return null;
        }
        s = s.replace(" ", "");
        byte[] baKeyword = new byte[s.length() / 2];
        for (int i = 0; i < baKeyword.length; i++) {
            try {
                baKeyword[i] = (byte) (0xff & Integer.parseInt(s.substring(i * 2, i * 2 + 2), 16));
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        try {
            s = new String(baKeyword, "UTF-8");
            new String();
        } catch (Exception e1) {
            e1.printStackTrace();
        }
        return s;
    }


    // 字符串转换为 map
    public static Map aToMap(String arr){
        Map map = new HashMap();
        if (null != arr) {
            String[] param = arr.split(";");
            for (int i = 0; i < param.length; i++) {
                //这里的 index 要 >-1 才是 map格式
                int index = param[i].indexOf(\'=\');
                if(index>-1)
                map.put(param[i].substring(0,index), param[i].substring((index + 1)));
            }
        }
        return map;
    }

    /**
     * 启动socketServer
     */
    public static void start(){
        ServerSocket server = null;
        try {
            server = new ServerSocket(8877);
            while (true) {
                System.out.println("listening...");

                Socket socket = server.accept();
                System.out.println("连接客户端地址：" + socket.getRemoteSocketAddress());
                System.out.println("connected...");
                ClientHandler handler = new ClientHandler(socket);
                Thread t = new Thread(handler);
                t.start();

            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (server != null) {
                try {
                    server.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    //测试方法
    public static void main(String[] args) throws InterruptedException {
     /*   for (int i = 0; i < 100; i++) {
            Thread.sleep(10000);
            System.out.println("测试");
            start();
        }*/

//        MessageParsing.calculation();
        start();
    }
}