【后附源碼】全網(wǎng)唯一MQTT結(jié)構(gòu)分析，不進(jìn)來(lái)看看？

static void Main(string[] args){    Console.WriteLine("歡迎關(guān)注朝夕教育，我是Jovan");    try    {        string ip = "127.0.0.1";        int port = 1883;        string username = "admin";        string password = "123456";        string clientId = "C001";
        //        Socket socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);        socketClient.Connect(ip, port);        Console.WriteLine(">>> TCP 連接通道已建立");
        // 建立MQTT連接        {            // 構(gòu)建MQTT報(bào)文            Listbytes = new List();
            bytes.AddRange(new byte[] { 0, 4 });// Protocol Name Length            bytes.AddRange(Encoding.ASCII.GetBytes("MQTT"));// Protocol Name            bytes.Add(4);
            byte flag = 0;            flag |= 128;// 用戶名標(biāo)記            flag |= 64; // 密碼標(biāo)記            flag |= 2;  // Clean Session 標(biāo)記            bytes.Add(flag);
            // KeepAlive            byte[] bytesKeepAlive = BitConverter.GetBytes((int)TimeSpan.FromSeconds(100).TotalSeconds);            bytes.Add(bytesKeepAlive[1]);            bytes.Add(bytesKeepAlive[0]);
            // ClientID            byte[] clienIdBytes = Encoding.ASCII.GetBytes(clientId);            bytes.Add((byte)(clienIdBytes.Length / 256));            bytes.Add((byte)(clienIdBytes.Length % 256));// 長(zhǎng)度占兩個(gè)字節(jié)            bytes.AddRange(clienIdBytes);
            // UserName            byte[] usernameBytes = Encoding.ASCII.GetBytes(username);            bytes.Add((byte)(usernameBytes.Length / 256));            bytes.Add((byte)(usernameBytes.Length % 256));// 長(zhǎng)度占兩個(gè)字節(jié)            bytes.AddRange(usernameBytes);
            // Password            byte[] passwordBytes = Encoding.ASCII.GetBytes(password);            bytes.Add((byte)(passwordBytes.Length / 256));            bytes.Add((byte)(passwordBytes.Length % 256));// 長(zhǎng)度占兩個(gè)字節(jié)            bytes.AddRange(passwordBytes);

            byte[] bufferLen = new byte[] { (byte)bytes.Count };
            MemoryStream memoryStream = new MemoryStream();            memoryStream.WriteByte(1 << 4);            memoryStream.Write(bufferLen, 0, (int)bufferLen.Length);            memoryStream.Write(bytes.ToArray(), 0, (int)bytes.Count);            byte[] array = memoryStream.ToArray();            memoryStream.Close();            socketClient.Send(array);        }    }    catch (Exception ex)    {        Console.WriteLine(ex.Message);    }    Console.ReadLine();}