lg_backend/langguanApi/Service/Gps808SocketServer.cs

using IceCoffee.FastSocket.Tcp;
using langguanApi.Model.Dto;
using langguanApi.Model;
using langguanApi.Service.HJ212;
using System.Net.Sockets;
using System.Net;
using System.Text;
using JT808.Protocol;
using Org.BouncyCastle.Utilities;
using LogicExtensions;
using JT808.Protocol.Enums;
using JT808.Protocol.MessageBody;

namespace langguanApi.Service
{
    public class Gps808SocketServer
    {
        /// <summary>
        /// 缓冲器
        /// </summary>
        private byte[] result = new byte[1024];
        /// <summary>
        /// 最大连接数
        /// </summary>
        private int maxClientCount;
        /// <summary>
        /// 服务IP地址
        /// </summary>
        private string ip;
        /// <summary>
        /// 服务端口号
        /// </summary>
        private int port => 5002;
        // 编码
        // private string code;
        /// <summary>
        /// 客户端列表
        /// </summary>
        private List<Socket> ClientSockets;
        /// <summary>
        /// IP终端
        /// </summary>
        private IPEndPoint ipEndPoint;
        /// <summary>
        /// 服务端Socket 
        /// </summary>
        private Socket ServerSocket;
        private static NetServer server;
        private static IceCoffee.FastSocket.Tcp.TcpClient client;
        /// <summary>
        /// 启动服务
        /// </summary>
        /// <returns></returns>
        public async Task Start()
        {
            ip = IPAddress.Any.ToString();
            server = new NetServer(ip, port);
            server.Started += OnNetServer_Started;
            server.ExceptionCaught += OnNetServer_ExceptionCaught;
            server.SessionStarted += OnNetServer_SessionStarted;
            server.SessionClosed += OnNetServer_SessionClosed;
            server.ReceivedData += OnNetServer_ReceivedData;
            server.SendData += OnNetServer_SendData;
            server.Start();
        }


        private void OnNetServer_Started()
        {
            Console.WriteLine($"开始监听gps: {ip}:{port}");
        }

        private void OnNetServer_SendData(NetSession session, NetPackage netPackage, string rawText)
        {
            Console.WriteLine($"发送给gps: {session.RemoteIPEndPoint}: {rawText}");
        }

        private void OnNetServer_SessionClosed(TcpSession session)
        {
            Console.WriteLine("会话关闭gps: " + session.RemoteIPEndPoint + ", 当前会话总数: " + server.SessionCount);
        }

        private static void OnNetServer_SessionStarted(TcpSession session)
        {
            Console.WriteLine("会话开始gps: " + session.RemoteIPEndPoint + ", 当前会话总数: " + server.SessionCount);
        }

        private async void OnNetServer_ReceivedData(TcpSession session, NetPackage netPackage, string rawText)
        {
            Console.WriteLine("收到自gps: " + session.RemoteIPEndPoint + ": " + rawText);
            byte[] bytes = rawText.ToBytes();
            //2.将数组反序列化
            //   var jT808Package =new JT808Serializer.Deserialize(bytes.AsSpan());
            //3.解析数据
            var jT808Package = new JT808Serializer().Deserialize(bytes);
            //4.数据包体
            JT808_0x0200 jT808_0x0200 = (JT808_0x0200)jT808Package.Bodies;
            var lon = jT808_0x0200.Lat;
            var lat= jT808_0x0200.Lng;
            Console.WriteLine("经度：" + lon + " 纬度：" + lat);
            //4.处理数据
            //5.返回数据
            //6.发送数据
            // st 27 =voc,st=31 cems, st=32,tsp, st=22 微站

        }

        private void OnNetServer_ExceptionCaught(Exception ex)
        {
            Console.WriteLine("Error in NetServer gps" + ex);
        }
        byte[] CallCRC(byte[] data)
        {
            string ccc = Convert.ToString(getCrc(data), 16).PadLeft(4, '0');
            return Encoding.ASCII.GetBytes(ccc.ToUpper());
        }
        private int getCrc(byte[] data)
        {
            int high;
            int flag;

            // 16位寄存器，所有数位均为1
            int wcrc = 0xffff;
            for (int i = 0; i < data.Length; i++)
            {
                // 16 位寄存器的高位字节
                high = wcrc >> 8;
                // 取被校验串的一个字节与 16 位寄存器的高位字节进行“异或”运算
                wcrc = high ^ data[i];

                for (int j = 0; j < 8; j++)
                {
                    flag = wcrc & 0x0001;
                    // 把这个 16 寄存器向右移一位
                    wcrc = wcrc >> 1;
                    // 若向右(标记位)移出的数位是 1,则生成多项式 1010 0000 0000 0001 和这个寄存器进行“异或”运算
                    if (flag == 1)
                        wcrc ^= 0xa001;
                }
            }

            return wcrc;
        }
    }
}