• C# TCP Server服务端多线程监听RFID读卡器客户端上传的读卡数据

    本示例使用设备介绍：液显WIFI无线网络HTTP协议RFID云读卡器可编程实时可控开关TTS语-淘宝网 (taobao.com) 

    1. using System;
    2. using System.Collections.Generic;
    3. using System.ComponentModel;
    4. using System.Data;
    5. using System.Drawing;
    6. using System.Linq;
    7. using System.Net;
    8. using System.Net.Sockets;
    9. using System.Text;
    10. using System.Threading;
    11. using System.Threading.Tasks;
    12. using System.Windows.Forms;
    13.  
    14.  
    15. namespace WindowsFormsApplication1
    16. {
    17.     public partial class Form13 : Form
    18.     {
    19.         public Form13()
    20.         {
    21.             InitializeComponent();
    22.             Control.CheckForIllegalCrossThreadCalls = false;
    23.         }
    24.  
    25.         Thread listenThread = null; //负责监听客户端的线程
    26.         Socket listenSocket = null; //负责监听客户端的套接字                                   
    27.         Socket interactSocket = null;//创建一个负责和客户端通信的套接字 
    28.  
    29.         Dictionary<string, Socket> dicSockets = new Dictionary<string, Socket>(); //套接字集合
    30.         Dictionary<string, Thread> dicThreads = new Dictionary<string, Thread>();  //线程集合
    31.         List<string> list_SealedClients = new List<string>();//被屏蔽用户的名单
    32.  
    33.         private void Form13_Load(object sender, EventArgs e)
    34.         {
    35.             GetIp();
    36.         }
    37.  
    38.         private void GetIp()
    39.         {
    40.             Form1 f1;
    41.             f1 = (Form1)this.Owner;
    42.             f1.Refresh();
    43.  
    44.             for (int i = 0; i < f1.comboBox4.Items.Count; i++)
    45.             {
    46.                 comboBox4.Items.Add(f1.comboBox4.Items[i]);
    47.             }
    48.             if (comboBox4.Items.Count > 0)
    49.             {
    50.                 comboBox4.SelectedIndex = 0;
    51.                 btn_conn.PerformClick();
    52.             }
    53.         }
    54.  
    55.         private void btn_conn_Click(object sender, EventArgs e)
    56.         {            
    57.             try
    58.             {
    59.                 if (btn_conn.Text == "开启服务器")
    60.                 {
    61.                     //(IPv4协议,双向,TCP协议)
    62.                     listenSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    63.  
    64.                     //网络结点endpoint需要IP和端口号
    65.                     //port是 与 address 关联的端口号，或为 0 以指定任何可用端口。port 以主机顺序排列。
    66.                     //IPEndPoint m_Endpoint = new IPEndPoint(IPAddress.Parse(txb_ip.Text.Trim()), int.Parse(txb_port.Text.Trim()));
    67.                     string ipadd = comboBox4.Text.Trim();
    68.                     IPEndPoint m_Endpoint = new IPEndPoint(IPAddress.Parse(ipadd), int.Parse(txb_port.Text.Trim()));
    69.  
    70.                     //绑定网络结点
    71.                     listenSocket.Bind(m_Endpoint);
    72.  
    73.                     //将监听Socket置于侦听状态,（backlog）:挂起连接队列的最大长度。
    74.                     listenSocket.Listen(10);
    75.  
    76.                     //创建一个线程执行的委托,无返回值
    77.                     ThreadStart threadFun = new ThreadStart(ListenConnectingRequest);
    78.  
    79.                     //创建一个监听线程 
    80.                     listenThread = new Thread(threadFun);
    81.  
    82.                     //线程设置为后台运行
    83.                     listenThread.IsBackground = true;
    84.  
    85.                     //启动线程
    86.                     listenThread.Start();
    87.  
    88.                     AddLog("开始监听客户端传来的信息!");
    89.                     btn_conn.Text = "关闭服务器";
    90.                 }
    91.                 else
    92.                 {
    93.                     //关闭监听
    94.                     listenSocket.Close();//关闭监听套接字，并释放
    95.                     listenThread.Abort();//强行中断
    96.                     AddLog("结束监听客户端传来的信息!");
    97.                     AddLog("关闭服务器，断开所有客户端用户的连接!");
    98.  
    99.                     //切断所有客户端的连接
    100.                     for (int i = 0; i < listBox1.Items.Count; i++)
    101.                     {
    102.                         string str = listBox1.Items[i].ToString();
    103.                         Socket m_socket = dicSockets[str];
    104.                         m_socket.Close();
    105.                     }
    106.                     btn_conn.Text = "开启服务器";
    107.                 }
    108.             }
    109.             catch (Exception f)
    110.             {
    111.                 MessageBox.Show("错误：" + f.ToString(), "警告", MessageBoxButtons.OK, MessageBoxIcon.Error);
    112.                 AddLog("服务端启动服务失败!");
    113.             }
    114.         }
    115.  
    116.         public void AddLog(string str)
    117.         {
    118.             if (listBox2.Items.Count > 50)
    119.             {
    120.                 listBox2.Items.Clear();
    121.             }
    122.             listBox2.Items.Add(str);
    123.             listBox2.SelectedIndex = listBox2.Items.Count - 1;
    124.         }
    125.  
    126.  
    127.         /// 
    128.         /// 监听客户端发来的请求
    129.         /// 
    130.         private void ListenConnectingRequest()
    131.         {
    132.             while (true)  //持续不断监听客户端发来的请求
    133.             {
    134.                 try
    135.                 {
    136.                     interactSocket = listenSocket.Accept();//阻塞，直到接收到客户端连接请求
    137.  
    138.                     // 向列表控件中添加客户端的IP信息;
    139.                     listBox1.Items.Add(interactSocket.RemoteEndPoint.ToString());
    140.  
    141.                     // 将与客户端连接的套接字对象添加到集合中；
    142.                     dicSockets.Add(interactSocket.RemoteEndPoint.ToString(), interactSocket);
    143.                     AddLog(DateTime.Now.ToString("hh:mm:ss.fff") + " 客户端" + interactSocket.RemoteEndPoint.ToString() + "连接服务器成功! "); //客户端IP
    144.  
    145.                     //创建一个通信线程 
    146.                     Thread threadRecvMsg = new Thread(new ParameterizedThreadStart(ServerRecvMsg));
    147.                     threadRecvMsg.IsBackground = true;
    148.                     //启动线程
    149.                     threadRecvMsg.Start(interactSocket);
    150.                     dicThreads.Add(interactSocket.RemoteEndPoint.ToString(), threadRecvMsg); // 将新建的线程 添加 到线程的集合中去。
    151.                 }
    152.                 catch (Exception)
    153.                 {
    154.                 }
    155.             }
    156.         }
    157.  
    158.         private void ServerRecvMsg(object m_InteractSocket)
    159.         {
    160.             Socket serverSocket = (Socket)m_InteractSocket; //类型转换 objec->Socket
    161.             string str = interactSocket.RemoteEndPoint.ToString();
    162.             while (true)
    163.             {
    164.                 //创建一个内存缓冲区 其大小为1024*1024字节  即1M
    165.                 byte[] arrServerRecMsg = new byte[1024 * 1024];
    166.                 try
    167.                 {
    168.                     //将接收到的信息存入到内存缓冲区,并返回其字节数组的长度
    169.                     int length = serverSocket.Receive(arrServerRecMsg);
    170.                     //如果屏蔽名单中有这个用户，屏蔽信息接收
    171.                     if (!list_SealedClients.Contains(str))
    172.                     {
    173.                         //将机器接受到的字节数组转换为人可以读懂的字符串
    174.                         string strSRecMsg = "";        //   Encoding.UTF8.GetString(arrServerRecMsg, 0, length);
    175.                         for (int i = 0; i < length; i++)
    176.                         {
    177.                             strSRecMsg = strSRecMsg + arrServerRecMsg[i].ToString("X2") + " ";
    178.                         }
    179.                         if (strSRecMsg.Length != 0)
    180.                         {
    181.                             //显示接收的信息
    182.                             string dispstr = DateTime.Now.ToString("hh:mm:ss.fff") + " FromIP " + interactSocket.RemoteEndPoint.ToString() + " ：" + strSRecMsg;
    183.                             AddLog(dispstr);
    184.                             //this.BeginInvoke(new Update1(EditUi1), dispstr, arrServerRecMsg, length);        //显示接收到的数据包，并根据情况回应设备
    185.                             AnalyticGetData(arrServerRecMsg, length, str);
    186.                         }
    187.                     }
    188.  
    189.                 }
    190.                 catch (Exception)
    191.                 {
    192.                     AddLog(DateTime.Now.ToString("hh:mm:ss.fff") + " 客户端" + str + "已断开服务器！");
    193.                     // 从通信套接字 集合中删除被中断连接的通信套接字；
    194.                     dicSockets.Remove(str);
    195.                     // 从通信线程集合中删除被中断连接的通信线程对象；
    196.                     dicThreads.Remove(str);
    197.                     // 从列表中移除被中断的连接IP
    198.                     listBox1.Items.Remove(str);
    199.                     // 从屏蔽列表从清除
    200.                     list_SealedClients.Remove(str);
    201.                     break;//结束该线程
    202.                 }
    203.             }
    204.         }
    205.  
    206.         private void ServerSingSenddata(byte[] senddata)
    207.         {
    208.             string strKey = "";
    209.             try
    210.             {
    211.                 strKey = listBox1.Text.Trim();
    212.                 if (string.IsNullOrEmpty(strKey))   // 判断是不是选择了发送的对象；
    213.                 {
    214.                     MessageBox.Show("请选择你要发送的在线客户端！", "警告", MessageBoxButtons.OK, MessageBoxIcon.Error);
    215.                 }
    216.                 else
    217.                 {
    218.                     if (!list_SealedClients.Contains(strKey))
    219.                     {
    220.                         string sendmsg = "";
    221.                         for (int i = 0; i < senddata.Length; i++)
    222.                         {
    223.                             sendmsg = sendmsg + senddata[i].ToString("X2") + " ";
    224.                         }
    225.                         dicSockets[strKey].Send(senddata);                                                         //显示发送的信息
    226.                         AddLog(DateTime.Now.ToString("hh:mm:ss.fff") + " SendTo " + strKey + " ：" + sendmsg);
    227.                         AddLog("");
    228.                     }
    229.                     else
    230.                     {
    231.                         MessageBox.Show(strKey + "已经被屏蔽！", "警告", MessageBoxButtons.OK, MessageBoxIcon.Error);
    232.                     }
    233.                 }
    234.             }
    235.             catch (Exception ex)
    236.             {
    237.                 MessageBox.Show("错误：" + ex.ToString(), "警告", MessageBoxButtons.OK, MessageBoxIcon.Error);
    238.                 AddLog(dicSockets[strKey].RemoteEndPoint.ToString() + "客户端已断开连接,无法发送信息！");
    239.             }
    240.         }
    241.  
    242.         private void button2_Click(object sender, EventArgs e)
    243.         {
    244.             listBox2.Items.Clear(); 
    245.         }
    246.  
    247.         private void button3_Click(object sender, EventArgs e)
    248.         {
    249.             string copystr;
    250.             copystr = "";
    251.             for (int i = 0; i <= listBox2.Items.Count - 1; i++)
    252.             {
    253.                 copystr = copystr + (string)listBox2.Items[i] + "\r\n";
    254.             }
    255.             Clipboard.Clear();
    256.             Clipboard.SetDataObject(copystr);
    257.  
    258.             MessageBox.Show("显示的数据报文已拷贝到剪切板", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
    259.         }
    260.  
    261.         private void button4_Click(object sender, EventArgs e)
    262.         {
    263.             AddLog("接收线程数量：" + dicThreads.Count.ToString());
    264.         }
    265.  
    266.         private void button5_Click(object sender, EventArgs e)
    267.         {
    268.             //1.没有选择退出
    269.             if (listBox1.SelectedIndex == -1)
    270.             {
    271.                 MessageBox.Show("请选择要断开的客户端！","警告", MessageBoxButtons.OK, MessageBoxIcon.Error);
    272.                 return;
    273.             }
    274.             //2.切断客户端的连接       
    275.             string RemoteEndPointStr = listBox1.SelectedItem.ToString();
    276.             AddLog("强制断开客户端" + RemoteEndPointStr + "的连接！");
    277.             listBox1.SelectedIndex = -1;
    278.             Socket disconnSocket = dicSockets[RemoteEndPointStr];
    279.             disconnSocket.Close();
    280.         }
    281.  
    282.         //解析接收到的数据信息，并回应驱动读卡器显示文字、蜂鸣响声、播报语音、开关继电器等
    283.         private void AnalyticGetData(byte[] getdata, int length, string IPort)
    284.         {
    285.             string msginf = "";
    286.             uint cardhao;
    287.             string cardnumberstr = "";
    288.             switch (getdata[0])
    289.             {
    290.                 case 0xc1:  //接收到IC读卡器读取的卡号
    291.                 case 0xcf:  //接收到IC离开读卡器
    292.                     if (getdata[0] == 0xc1)
    293.                     {
    294.                         msginf = "数据解析：IC读卡器刷卡数据";
    295.                     }
    296.                     else { msginf = "数据解析：IC卡离开读卡器"; }
    297.                     msginf = msginf + "，IP[" + getdata[1].ToString() + "." + getdata[2].ToString() + "." + getdata[3].ToString() + "." + getdata[4].ToString();
    298.                     msginf = msginf + "，机号[" + Convert.ToString(getdata[5] + getdata[6] * 256) + "]，数据包序号[" + Convert.ToString(getdata[7] + getdata[8] * 256) + "]，卡号长度[" + Convert.ToString(getdata[9]) + "]，16进制卡号[";
    299.                     for (int i = 10; i < 10 + getdata[9]; i++)
    300.                     {
    301.                         msginf = msginf + getdata[i].ToString("X2");
    302.                     }
    303.                     cardhao = (uint)(getdata[13] * 256 * 256 * 256 + getdata[12] * 256 * 256 + getdata[11] * 256 + getdata[10]);
    304.                     cardnumberstr = "0000000000" + Convert.ToString(cardhao);//卡号
    305.                     cardnumberstr = cardnumberstr.Substring(cardnumberstr.Length - 10, 10);
    306.                     msginf = msginf + "]，转10进制卡号[" + cardnumberstr;
    307.  
    308.                     msginf = msginf +  "]，唯一设备序号[";
    309.                     for (int i = 10 + getdata[9]; i < length; i++)
    310.                     {
    311.                         msginf = msginf + getdata[i].ToString("X2");
    312.                     }
    313.                     msginf = msginf + "]";
    314.                     AddLog(msginf);
    315.                     AddLog("");
    316.                     Response(IPort);
    317.                     break;
    318.  
    319.                 case 0xd1: //接收到ID读卡器读取的卡号
    320.                 case 0xdf: //接收到ID卡离开读卡器
    321.                     if (getdata[0] == 0xd1)
    322.                     {
    323.                         msginf = "数据解析：ID读卡器刷卡数据";
    324.                     }
    325.                     else { msginf = "数据解析：ID卡离开读卡器"; }
    326.                     msginf = msginf + "，IP[" + getdata[1].ToString() + "." + getdata[2].ToString() + "." + getdata[3].ToString() + "." + getdata[4].ToString();
    327.                     msginf = msginf + "，机号[" + Convert.ToString(getdata[5] + getdata[6] * 256) + "]，数据包序号[" + Convert.ToString(getdata[7] + getdata[8] * 256) + "]";
    328.  
    329.                     cardhao = (uint)(getdata[12] * 256 * 256 * 256 + getdata[11] * 256 * 256 + getdata[10] * 256 + getdata[9]);
    330.                     cardnumberstr = "0000000000" + Convert.ToString(cardhao);//卡号
    331.                     cardnumberstr = cardnumberstr.Substring(cardnumberstr.Length - 10, 10);
    332.  
    333.                     msginf = msginf + "，16进制卡号[" + getdata[9].ToString("X2") + getdata[10].ToString("X2") + getdata[11].ToString("X2") + getdata[12].ToString("X2") + getdata[13].ToString("X2") + "]，转10进制卡号[" + cardnumberstr + "]";
    334.  
    335.                     msginf = msginf + "，唯一设备序号[";
    336.                     for (int i = 14; i < length; i++)
    337.                     {
    338.                         msginf = msginf + getdata[i].ToString("X2");
    339.                     }
    340.                     msginf = msginf + "]";
    341.                     AddLog(msginf);
    342.                     AddLog("");
    343.                     Response(IPort);
    344.                     break;
    345.  
    346.                 case 0xf3: //接收到读卡器心跳包
    347.                     msginf = "数据解析：读卡器读卡器心跳包，IP[" + getdata[1].ToString() + "." + getdata[2].ToString() + "." + getdata[3].ToString() + "." + getdata[4].ToString();
    348.                     msginf = msginf + "，机号[" + Convert.ToString(getdata[5] + getdata[6] * 256) + "]，数据包序号[" + Convert.ToString(getdata[7] + getdata[8] * 256) + "]，心跳包类型[" + Convert.ToString(getdata[9]) + "]";
    349.                     msginf = msginf + "，长度[" + Convert.ToString(getdata[10]) + "]";
    350.                     msginf = msginf + "，继电器状态[" + getdata[11].ToString("X2") + "]";
    351.                     msginf = msginf + "，外部输入状态[" + getdata[12].ToString("X2") + "]";
    352.                     msginf = msginf + "，随机动态码[" + getdata[13].ToString("X2") + getdata[14].ToString("X2") + getdata[15].ToString("X2") + getdata[16].ToString("X2") + "]";
    353.                     for (int i = 17; i < length; i++)
    354.                     {
    355.                         msginf = msginf + getdata[i].ToString("X2");
    356.                     }
    357.                     msginf = msginf + "]";
    358.                     AddLog(msginf);
    359.                     AddLog("");
    360.                     break;
    361.             }
    362.         }
    363.  
    364.         //回应读卡器驱动显示文字、蜂鸣响声、播报语音等
    365.         private void Response(string IPort)
    366.         {
    367.             byte[] databuf = new byte[280];
    368.             int i;
    369.             int dispbytes;    //显示文字节数
    370.             int speakbytes;   //语音播报字节表
    371.             int sendbytes;    //报文数据长度           
    372.  
    373.             dispbytes = 34;   //双行屏34，四行屏72显示长度，如不显示文字可以为0
    374.  
    375.             string strls = "[v";
    376.             if (SYDX.Value <= 16)
    377.             {
    378.                 strls = strls + (SYDX.Value.ToString()).Trim() + "]";  //设置语音大小，在需要发送的语音字符串中任何位置加入[v10],表示将音量调到10级(范围0~16，0表示静音，16最大，每次重开机后，音量重置为10级)！
    379.             }
    380.             else { strls = strls + "16]"; }
    381.  
    382.             strls = strls + textBox12.Text.Trim();
    383.  
    384.             byte[] SpeakArr = System.Text.Encoding.GetEncoding(936).GetBytes(strls);//TTS语音转换为Ansi
    385.             speakbytes = SpeakArr.GetLength(0);             //语音长度
    386.             sendbytes = 11 + dispbytes + speakbytes + 4;    //总计发送数据长度
    387.  
    388.             databuf[0] = 0x5C;      //表示驱动蜂鸣器+TTS组合语音+显示文字+继电器
    389.             databuf[1] = 0;         //机号低位,
    390.             databuf[2] = 0;         //机号高位，如果高低位都为0表示任意机号，TCP是点对点通讯
    391.  
    392.             if (checkBox2.Checked)   //可以同时发出声响
    393.             {
    394.                 databuf[3] = (byte)(comboBox3.SelectedIndex);
    395.                 if (radioButton2.Checked)  //背光灯不变
    396.                 {
    397.                     databuf[3] = (byte)(databuf[3] | 0x80);
    398.                 }
    399.             }
    400.             else
    401.             {
    402.                 databuf[3] = 0xff;//不发出声响
    403.                 if (radioButton2.Checked)  //背光灯不变
    404.                 {
    405.                     databuf[3] = (byte)(databuf[3] & 0x80);
    406.                 }
    407.             }
    408.  
    409.             switch (comboBox2.SelectedIndex)  //继电器
    410.             {
    411.                 case 1:
    412.                     databuf[4] = 0xF1;
    413.                     break;
    414.                 case 2:
    415.                     databuf[4] = 0xF2;
    416.                     break;
    417.                 case 3:
    418.                     databuf[4] = 0xF3;
    419.                     break;
    420.                 case 4:
    421.                     databuf[4] = 0xF4;
    422.                     break;
    423.                 case 5:
    424.                     databuf[4] = 0xF5;
    425.                     break;
    426.                 case 6:
    427.                     databuf[4] = 0xF6;
    428.                     break;
    429.                 case 7:
    430.                     databuf[4] = 0xF7;
    431.                     break;
    432.                 case 8:
    433.                     databuf[4] = 0xF8;
    434.                     break;
    435.                 default:
    436.                     databuf[4] = 0xF0;
    437.                     break;
    438.             }
    439.             i = Convert.ToInt32(textBox11.Text);      //继电器时长
    440.             databuf[5] = (byte)(i % 256);
    441.             databuf[6] = (byte)(i / 256);
    442.  
    443.             databuf[7] = (byte)(numericUpDown1.Value);//显示保留时间，单位为秒，为255时表示永久显示
    444.             databuf[8] = 0;                           //在显示屏中的哪个位置开始
    445.             databuf[9] = (byte)dispbytes;             //显示字符串长度 0-34为全屏
    446.  
    447.             databuf[10] = (byte)speakbytes;           //TTS语音长度
    448.  
    449.             strls = textBox12.Text + "                                            ";
    450.             byte[] strlsansi = System.Text.Encoding.GetEncoding(936).GetBytes(strls);//显示文字转换为Ansi
    451.             for (i = 0; i < speakbytes; i++)
    452.             {
    453.                 databuf[11 + i] = (Byte)strlsansi[i];
    454.             }
    455.  
    456.             for (i = 0; i < speakbytes; i++)          //连播语音代码
    457.             {
    458.                 databuf[11 + databuf[9] + i] = (Byte)SpeakArr[i];
    459.             }
    460.  
    461.             databuf[10 + databuf[9] + speakbytes + 1] = 0x55;   //防干扰后缀
    462.             databuf[10 + databuf[9] + speakbytes + 2] = 0xAA;
    463.             databuf[10 + databuf[9] + speakbytes + 3] = 0x66;
    464.             databuf[10 + databuf[9] + speakbytes + 4] = 0x99;
    465.  
    466.             int sendlen = 10 + databuf[9] + speakbytes + 5;
    467.             byte[] sendbuf = new byte[sendlen];
    468.             string dispstr = DateTime.Now.ToString("hh:mm:ss.fff") + " SendTo " + IPort + " ：";
    469.             for (i = 0; i < sendlen; i++)          //连播语音代码
    470.             {
    471.                 sendbuf[i] = databuf[i];
    472.                 dispstr = dispstr + databuf[i].ToString("X2") + " ";
    473.             }
    474.  
    475.             dicSockets[IPort].Send(sendbuf);
    476.             AddLog(dispstr);
    477.             AddLog(" ");
    478.         }
    479.  
    480.         private void button6_Click(object sender, EventArgs e)
    481.         {
    482.             byte[] sendbuf = new byte[4];
    483.             sendbuf[0] = 0x96;      //声响指令
    484.             sendbuf[1] = 0;         //机号低位,
    485.             sendbuf[2] = 0;         //机号高位，如果高低位都为0表示任意机号，TCP是点对点通讯
    486.             sendbuf[3] = (byte)(comboBox3.SelectedIndex);
    487.  
    488.             ServerSingSenddata(sendbuf);
    489.         }
    490.  
    491.         private void button7_Click(object sender, EventArgs e)
    492.         {
    493.             byte[] sendbuf = new byte[6];
    494.             sendbuf[0] = 0x78;      //继电器指令
    495.             sendbuf[1] = 0;         //机号低位,
    496.             sendbuf[2] = 0;         //机号高位，如果高低位都为0表示任意机号，TCP是点对点通讯
    497.  
    498.             switch (comboBox2.SelectedIndex)
    499.             {
    500.                 case 1:
    501.                     sendbuf[3] = 0xF1;
    502.                     break;
    503.                 case 2:
    504.                     sendbuf[3] = 0xF2;
    505.                     break;
    506.                 case 3:
    507.                     sendbuf[3] = 0xF3;
    508.                     break;
    509.                 case 4:
    510.                     sendbuf[3] = 0xF4;
    511.                     break;
    512.                 case 5:
    513.                     sendbuf[3] = 0xF5;
    514.                     break;
    515.                 case 6:
    516.                     sendbuf[3] = 0xF6;
    517.                     break;
    518.                 case 7:
    519.                     sendbuf[3] = 0xF7;
    520.                     break;
    521.                 case 8:
    522.                     sendbuf[3] = 0xF8;
    523.                     break;
    524.                 default:
    525.                     sendbuf[3] = 0xF0;
    526.                     break;
    527.             }
    528.             int i = Convert.ToInt32(textBox11.Text);//延时
    529.             sendbuf[4] = (byte)(i % 256);
    530.             sendbuf[5] = (byte)(i / 256);
    531.  
    532.             ServerSingSenddata(sendbuf);
    533.         }
    534.  
    535.         private void button8_Click(object sender, EventArgs e)
    536.         {
    537.             byte[] sendbuf = new byte[6];
    538.             sendbuf[0] = 0x78;      //继电器指令
    539.             sendbuf[1] = 0;         //机号低位,
    540.             sendbuf[2] = 0;         //机号高位，如果高低位都为0表示任意机号，TCP是点对点通讯
    541.  
    542.             switch (comboBox2.SelectedIndex)
    543.             {
    544.                 case 1:
    545.                     sendbuf[3] = 0xE1;
    546.                     break;
    547.                 case 2:
    548.                     sendbuf[3] = 0xE2;
    549.                     break;
    550.                 case 3:
    551.                     sendbuf[3] = 0xE3;
    552.                     break;
    553.                 case 4:
    554.                     sendbuf[3] = 0xE4;
    555.                     break;
    556.                 case 5:
    557.                     sendbuf[3] = 0xE5;
    558.                     break;
    559.                 case 6:
    560.                     sendbuf[3] = 0xE6;
    561.                     break;
    562.                 case 7:
    563.                     sendbuf[3] = 0xE7;
    564.                     break;
    565.                 case 8:
    566.                     sendbuf[3] = 0xE8;
    567.                     break;
    568.                 default:
    569.                     sendbuf[3] = 0xE0;
    570.                     break;
    571.             }
    572.             int i = Convert.ToInt32(textBox11.Text);//延时
    573.             sendbuf[4] = (byte)(i % 256);
    574.             sendbuf[5] = (byte)(i / 256);
    575.  
    576.             ServerSingSenddata(sendbuf);
    577.         }
    578.  
    579.         private void button10_Click(object sender, EventArgs e)
    580.         {
    581.             string strls;
    582.             byte[] sendbuf = new byte[39];
    583.             int i;
    584.  
    585.             sendbuf[0] = 0x5a;      //显示文字的指令
    586.             sendbuf[1] = 0;         //机号低位,
    587.             sendbuf[2] = 0;         //机号高位，如果高低位都为0表示任意机号，TCP是点对点通讯
    588.  
    589.             if (checkBox2.Checked)   //可以同时发出声响
    590.             {
    591.                 sendbuf[3] = (byte)(comboBox3.SelectedIndex);
    592.                 if (radioButton2.Checked)  //背光灯不变
    593.                 {
    594.                     sendbuf[3] = (byte)(sendbuf[3] | 0x80);
    595.                 }
    596.             }
    597.             else
    598.             {
    599.                 sendbuf[3] = 0xff;//不发出声响
    600.                 if (radioButton2.Checked)  //背光灯不变
    601.                 {
    602.                     sendbuf[3] = (byte)(sendbuf[3] & 0x80);
    603.                 }
    604.             }
    605.  
    606.             sendbuf[4] = (byte)(numericUpDown1.Value);//显示保留时间，单位为秒，为255时表示永久显示
    607.  
    608.             strls = textBox12.Text + "                                        ";
    609.             byte[] strlsansi = System.Text.Encoding.GetEncoding(936).GetBytes(strls);//转换为Ansi //显示文字的ASCII码
    610.  
    611.             for (i = 0; i < 34; i++)
    612.             {
    613.                 sendbuf[5 + i] = (Byte)strlsansi[i];
    614.             }
    615.             ServerSingSenddata(sendbuf);   
    616.         }
    617.  
    618.         private void button9_Click(object sender, EventArgs e)
    619.         {
    620.             byte[] databuf = new byte[280];
    621.             int i;
    622.             int dispbytes;    //显示文字节数
    623.             int speakbytes;   //语音播报字节表
    624.             int sendbytes;    //报文数据长度           
    625.  
    626.             dispbytes = 34;   //双行屏34，四行屏72显示长度，如不显示文字可以为0
    627.  
    628.             string strls = "[v";
    629.             if (SYDX.Value <= 16)
    630.             {
    631.                 strls = strls + (SYDX.Value.ToString()).Trim() + "]";  //设置语音大小，在需要发送的语音字符串中任何位置加入[v10],表示将音量调到10级(范围0~16，0表示静音，16最大，每次重开机后，音量重置为10级)！
    632.             }
    633.             else { strls = strls + "16]"; }
    634.  
    635.             strls = strls + textBox12.Text.Trim();
    636.  
    637.             byte[] SpeakArr = System.Text.Encoding.GetEncoding(936).GetBytes(strls);//TTS语音转换为Ansi
    638.             speakbytes = SpeakArr.GetLength(0);             //语音长度
    639.             sendbytes = 11 + dispbytes + speakbytes + 4;    //总计发送数据长度
    640.  
    641.             databuf[0] = 0x5C;      //表示驱动蜂鸣器+TTS组合语音+显示文字+继电器
    642.             databuf[1] = 0;         //机号低位,
    643.             databuf[2] = 0;         //机号高位，如果高低位都为0表示任意机号，TCP是点对点通讯
    644.  
    645.             if (checkBox2.Checked)   //可以同时发出声响
    646.             {
    647.                 databuf[3] = (byte)(comboBox3.SelectedIndex);
    648.                 if (radioButton2.Checked)  //背光灯不变
    649.                 {
    650.                     databuf[3] = (byte)(databuf[3] | 0x80);
    651.                 }
    652.             }
    653.             else
    654.             {
    655.                 databuf[3] = 0xff;//不发出声响
    656.                 if (radioButton2.Checked)  //背光灯不变
    657.                 {
    658.                     databuf[3] = (byte)(databuf[3] & 0x80);
    659.                 }
    660.             }
    661.  
    662.             switch (comboBox2.SelectedIndex)  //继电器
    663.             {
    664.                 case 1:
    665.                     databuf[4] = 0xF1;
    666.                     break;
    667.                 case 2:
    668.                     databuf[4] = 0xF2;
    669.                     break;
    670.                 case 3:
    671.                     databuf[4] = 0xF3;
    672.                     break;
    673.                 case 4:
    674.                     databuf[4] = 0xF4;
    675.                     break;
    676.                 case 5:
    677.                     databuf[4] = 0xF5;
    678.                     break;
    679.                 case 6:
    680.                     databuf[4] = 0xF6;
    681.                     break;
    682.                 case 7:
    683.                     databuf[4] = 0xF7;
    684.                     break;
    685.                 case 8:
    686.                     databuf[4] = 0xF8;
    687.                     break;
    688.                 default:
    689.                     databuf[4] = 0xF0;
    690.                     break;
    691.             }
    692.             i = Convert.ToInt32(textBox11.Text);      //继电器时长
    693.             databuf[5] = (byte)(i % 256);
    694.             databuf[6] = (byte)(i / 256);
    695.  
    696.             databuf[7] = (byte)(numericUpDown1.Value);//显示保留时间，单位为秒，为255时表示永久显示
    697.             databuf[8] = 0;                           //在显示屏中的哪个位置开始
    698.             databuf[9] = (byte)dispbytes;             //显示字符串长度 0-34为全屏
    699.  
    700.             databuf[10] = (byte)speakbytes;           //TTS语音长度
    701.  
    702.             strls = textBox12.Text + "                                            ";
    703.             byte[] strlsansi = System.Text.Encoding.GetEncoding(936).GetBytes(strls);//显示文字转换为Ansi
    704.             for (i = 0; i < speakbytes; i++)
    705.             {
    706.                 databuf[11 + i] = (Byte)strlsansi[i];
    707.             }
    708.  
    709.             for (i = 0; i < speakbytes; i++)          //连播语音代码
    710.             {
    711.                 databuf[11 + databuf[9] + i] = (Byte)SpeakArr[i];
    712.             }
    713.  
    714.             databuf[10 + databuf[9] + speakbytes + 1] = 0x55;   //防干扰后缀
    715.             databuf[10 + databuf[9] + speakbytes + 2] = 0xAA;
    716.             databuf[10 + databuf[9] + speakbytes + 3] = 0x66;
    717.             databuf[10 + databuf[9] + speakbytes + 4] = 0x99;
    718.  
    719.             int sendlen = 10 + databuf[9] + speakbytes + 5;
    720.             byte[] sendbuf = new byte[sendlen];
    721.             for (i = 0; i < sendlen; i++)          //连播语音代码
    722.             {
    723.                 sendbuf[i] = databuf[i];
    724.             }
    725.             ServerSingSenddata(sendbuf);   
    726.         }
    727.  
    728.         private void comboBox4_SelectedIndexChanged(object sender, EventArgs e)
    729.         {
    730.             try
    731.             {                
    732.                     listenSocket.Close();//关闭监听套接字，并释放
    733.                     listenThread.Abort();//强行中断
    734.                     AddLog("结束监听客户端传来的信息!");
    735.                     AddLog("关闭服务器，断开所有客户端用户的连接!");
    736.  
    737.                     //切断所有客户端的连接
    738.                     for (int i = 0; i < listBox1.Items.Count; i++)
    739.                     {
    740.                         string str = listBox1.Items[i].ToString();
    741.                         Socket m_socket = dicSockets[str];
    742.                         m_socket.Close();
    743.                     }
    744.                     btn_conn.Text = "开启服务器";    
    745.             }
    746.             catch (Exception f)
    747.             {
    748.                 btn_conn.Text = "开启服务器";
    749.             }
    750.         }
    751.  
    752.         private void Form13_FormClosed(object sender, FormClosedEventArgs e)
    753.         {
    754.             try
    755.             {
    756.                 listenSocket.Close();//关闭监听套接字，并释放
    757.                 listenThread.Abort();//强行中断
    758.                 AddLog("结束监听客户端传来的信息!");
    759.                 AddLog("关闭服务器，断开所有客户端用户的连接!");
    760.  
    761.                 //切断所有客户端的连接
    762.                 for (int i = 0; i < listBox1.Items.Count; i++)
    763.                 {
    764.                     string str = listBox1.Items[i].ToString();
    765.                     Socket m_socket = dicSockets[str];
    766.                     m_socket.Close();
    767.                 }
    768.                 btn_conn.Text = "开启服务器";
    769.             }
    770.             catch (Exception f)
    771.             {
    772.                 btn_conn.Text = "开启服务器";
    773.             }
    774.         }
    775.     }
    776. }

  • 相关阅读:
    C++学习笔记（Ⅳ）：C++提高编程
    编写基础程序:Hello World
    react: zustand数据缓存
    单链表反转
    中国传统美食网页HTML代码 学生网页课程设计期末作业下载 美食大学生网页设计制作成品下载 DW餐饮美食网页作业代码下载
    【LeetCode】 前K个高频单词 两种解法
    C++高精度乘法（高精度乘低精度）
    echarts：graph图表拖拽节点
    AndroidStudio 导入项目模块失败
    管张汇泓：一份邮件把我带到了开源世界｜OneFlow U
  • 原文地址：https://blog.csdn.net/zhangjin7422/article/details/134267010