cim/cim-client-sdk/cim-dotnet-sdk/CIM_Standard/SocketHelper.cs

using Google.Protobuf;
using Google.Protobuf.Collections;
using System;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Runtime.Serialization;
using System.Runtime.Serialization.Formatters.Binary;
using System.Threading;
using System.Threading.Tasks;

namespace CIM_Standard
{
    public static class SocketHelper
    {
        public static TcpClient client = new TcpClient();

        public const byte PONG = 0;

        public const byte PING_TYPE = 1;

        public const byte MESSAGE_TYPE = 2;

        public const byte SEND_BODY = 3;

        public const byte REPLY_BODY = 4;

        public const int FORCE_LGOUT = 255;

        public const string APP_CHANNEL = "DotNet";

        public const string APP_VERSION = "1.0.0";

        public const string APP_PACKAGE = "com.farsunset.cim";

        public async static Task CIMConnect(string host,int port,Action<MessageModel> action) 
        {

            try
            {
                await client.ConnectAsync(host,port);


                while (true)
                {
                    Thread.Sleep(1000);
                    if (client.Connected)
                    {
                        Console.WriteLine("-------------------开始登录-------------");
                        await SendLoginMessage();
                        break;
                    }
                }

                await Task.Run(()=> 
                {
                    ReceiveMessage(action);
                });

            } 
            catch (Exception ex) 
            {
                Console.WriteLine(ex.Message);
            }
        }

    

        public async static Task Pong()
        {
            byte[] body = System.Text.Encoding.UTF8.GetBytes("PONG");
            byte[] header = createLengthHeader(PONG, body.Length);
            byte[] data = new byte[body.Length + 3];
            data[0] = header[0];
            data[1] = header[1];
            data[2] = header[2];
            body.CopyTo(data,3);
            await SendMessage(data);
        }

        public async static Task SendLoginMessage() 
        {
            try 
            {
                long timestamp =Convert.ToInt64 ((DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, 0)).TotalSeconds);
                var body = new SentBodyModel();
                body.Key = "client_bind";
                body.Timestamp = timestamp;
                body.Data.Add("uid", "111111111111");
                body.Data.Add("channel", APP_CHANNEL);
                body.Data.Add("appVersion", APP_VERSION);
                body.Data.Add("osVersion", "NetStandard2.0");
                body.Data.Add("packageName", APP_PACKAGE);
                body.Data.Add("deviceId", "34519adfsdsfdfdf");
                body.Data.Add("deviceName", "NetCore3.1");
                body.Data.Add("language", "Zh_cn");
                byte[] body_data = body.ToByteArray();
                byte[] data = new byte[body_data.Length + 3];
                byte[] header = createLengthHeader(SEND_BODY, body_data.Length);
                data[0] = header[0];
                data[1] = header[1];
                data[2] = header[2];
               body_data.CopyTo(data, 3);
                await SendMessage(data);
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }

        private static async Task SendMessage(byte[] bytes) 
        {
            NetworkStream networkStream = client.GetStream();
            await networkStream.WriteAsync(bytes, 0, bytes.Length);
        }

        private static byte[] createLengthHeader(byte type, int length)
        {
            byte[] header = new byte[3];
            header[0] = type;
            header[1] = (byte)(length & 0xff);
            header[2] = (byte)((length >> 8) & 0xff);
            return header;
        }

        public static void ReceiveMessage(Action<MessageModel> action)
        {
            NetworkStream networkStream = client.GetStream();
            while (true)
            {
                byte[] buffer = new byte[3];
                networkStream.Read(buffer, 0, buffer.Length);
                int l = (buffer[1] & 0xff);
                int h = (buffer[2] & 0xff);
                int length = (l | h << 8);
                if (buffer[0] == PING_TYPE)
                {
                    byte[] msg = new byte[length];
                    networkStream.Read(msg, 0, msg.Length);
                    Pong().Wait();
                }
                else if (buffer[0] == REPLY_BODY)
                {
                    byte[] msg = new byte[length];
                    networkStream.Read(msg, 0, msg.Length);
                    ReplyBodyModel model = new ReplyBodyModel();
                    model.MergeFrom(msg);
                    if (model.Key.Equals("client_bind")) 
                    {
                        Console.WriteLine("绑定账户成功!");
                    }
                }
                else if (buffer[0] == MESSAGE_TYPE)
                {
                    byte[] msg = new byte[length];
                    networkStream.Read(msg, 0, msg.Length);
                    MessageModel model = new MessageModel();
                    model.MergeFrom(msg);
                    action(model);
                }
            }
        }
    }
}