C# TCP Server服务端多线程监听RFID读卡器客户端上传的读卡数据
本示例使用设备介绍：液显WIFI无线网络HTTP协议RFID云读卡器可编程实时可控开关TTS语-淘宝网 (taobao.com)
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;namespace WindowsFormsApplication1
{public partial class Form13 : Form{public Form13(){InitializeComponent();Control.CheckForIllegalCrossThreadCalls = false;}Thread listenThread = null; //负责监听客户端的线程Socket listenSocket = null; //负责监听客户端的套接字 Socket interactSocket = null;//创建一个负责和客户端通信的套接字 Dictionary<string, Socket> dicSockets = new Dictionary<string, Socket>(); //套接字集合Dictionary<string, Thread> dicThreads = new Dictionary<string, Thread>(); //线程集合List<string> list_SealedClients = new List<string>();//被屏蔽用户的名单private void Form13_Load(object sender, EventArgs e){GetIp();}private void GetIp(){Form1 f1;f1 = (Form1)this.Owner;f1.Refresh();for (int i = 0; i < f1.comboBox4.Items.Count; i++){comboBox4.Items.Add(f1.comboBox4.Items[i]);}if (comboBox4.Items.Count > 0){comboBox4.SelectedIndex = 0;btn_conn.PerformClick();}}private void btn_conn_Click(object sender, EventArgs e){ try{if (btn_conn.Text == "开启服务器"){//(IPv4协议,双向,TCP协议)listenSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//网络结点endpoint需要IP和端口号//port是 与 address 关联的端口号，或为 0 以指定任何可用端口。port 以主机顺序排列。//IPEndPoint m_Endpoint = new IPEndPoint(IPAddress.Parse(txb_ip.Text.Trim()), int.Parse(txb_port.Text.Trim()));string ipadd = comboBox4.Text.Trim();IPEndPoint m_Endpoint = new IPEndPoint(IPAddress.Parse(ipadd), int.Parse(txb_port.Text.Trim()));//绑定网络结点listenSocket.Bind(m_Endpoint);//将监听Socket置于侦听状态,（backlog）:挂起连接队列的最大长度。listenSocket.Listen(10);//创建一个线程执行的委托,无返回值ThreadStart threadFun = new ThreadStart(ListenConnectingRequest);//创建一个监听线程 listenThread = new Thread(threadFun);//线程设置为后台运行listenThread.IsBackground = true;//启动线程listenThread.Start();AddLog("开始监听客户端传来的信息!");btn_conn.Text = "关闭服务器";}else{//关闭监听listenSocket.Close();//关闭监听套接字，并释放listenThread.Abort();//强行中断AddLog("结束监听客户端传来的信息!");AddLog("关闭服务器，断开所有客户端用户的连接!");//切断所有客户端的连接for (int i = 0; i < listBox1.Items.Count; i++){string str = listBox1.Items[i].ToString();Socket m_socket = dicSockets[str];m_socket.Close();}btn_conn.Text = "开启服务器";}}catch (Exception f){MessageBox.Show("错误：" + f.ToString(), "警告", MessageBoxButtons.OK, MessageBoxIcon.Error);AddLog("服务端启动服务失败!");}}public void AddLog(string str){if (listBox2.Items.Count > 50){listBox2.Items.Clear();}listBox2.Items.Add(str);listBox2.SelectedIndex = listBox2.Items.Count - 1;}/// <summary>/// 监听客户端发来的请求/// </summary>private void ListenConnectingRequest(){while (true) //持续不断监听客户端发来的请求{try{interactSocket = listenSocket.Accept();//阻塞，直到接收到客户端连接请求// 向列表控件中添加客户端的IP信息;listBox1.Items.Add(interactSocket.RemoteEndPoint.ToString());// 将与客户端连接的套接字对象添加到集合中；dicSockets.Add(interactSocket.RemoteEndPoint.ToString(), interactSocket);AddLog(DateTime.Now.ToString("hh:mm:ss.fff") + " 客户端" + interactSocket.RemoteEndPoint.ToString() + "连接服务器成功! "); //客户端IP//创建一个通信线程 Thread threadRecvMsg = new Thread(new ParameterizedThreadStart(ServerRecvMsg));threadRecvMsg.IsBackground = true;//启动线程threadRecvMsg.Start(interactSocket);dicThreads.Add(interactSocket.RemoteEndPoint.ToString(), threadRecvMsg); // 将新建的线程 添加 到线程的集合中去。}catch (Exception){}}}private void ServerRecvMsg(object m_InteractSocket){Socket serverSocket = (Socket)m_InteractSocket; //类型转换 objec->Socketstring str = interactSocket.RemoteEndPoint.ToString();while (true){//创建一个内存缓冲区 其大小为1024*1024字节 即1Mbyte[] arrServerRecMsg = new byte[1024 * 1024];try{//将接收到的信息存入到内存缓冲区,并返回其字节数组的长度int length = serverSocket.Receive(arrServerRecMsg);//如果屏蔽名单中有这个用户，屏蔽信息接收if (!list_SealedClients.Contains(str)){//将机器接受到的字节数组转换为人可以读懂的字符串string strSRecMsg = ""; // Encoding.UTF8.GetString(arrServerRecMsg, 0, length);for (int i = 0; i < length; i++){strSRecMsg = strSRecMsg + arrServerRecMsg[i].ToString("X2") + " ";}if (strSRecMsg.Length != 0){//显示接收的信息string dispstr = DateTime.Now.ToString("hh:mm:ss.fff") + " FromIP " + interactSocket.RemoteEndPoint.ToString() + " ：" + strSRecMsg;AddLog(dispstr);//this.BeginInvoke(new Update1(EditUi1), dispstr, arrServerRecMsg, length); //显示接收到的数据包，并根据情况回应设备AnalyticGetData(arrServerRecMsg, length, str);}}}catch (Exception){AddLog(DateTime.Now.ToString("hh:mm:ss.fff") + " 客户端" + str + "已断开服务器！");// 从通信套接字 集合中删除被中断连接的通信套接字；dicSockets.Remove(str);// 从通信线程集合中删除被中断连接的通信线程对象；dicThreads.Remove(str);// 从列表中移除被中断的连接IPlistBox1.Items.Remove(str);// 从屏蔽列表从清除list_SealedClients.Remove(str);break;//结束该线程}}}private void ServerSingSenddata(byte[] senddata){string strKey = "";try{strKey = listBox1.Text.Trim();if (string.IsNullOrEmpty(strKey)) // 判断是不是选择了发送的对象；{MessageBox.Show("请选择你要发送的在线客户端！", "警告", MessageBoxButtons.OK, MessageBoxIcon.Error);}else{if (!list_SealedClients.Contains(strKey)){string sendmsg = "";for (int i = 0; i < senddata.Length; i++){sendmsg = sendmsg + senddata[i].ToString("X2") + " ";}dicSockets[strKey].Send(senddata); //显示发送的信息AddLog(DateTime.Now.ToString("hh:mm:ss.fff") + " SendTo " + strKey + " ：" + sendmsg);AddLog("");}else{MessageBox.Show(strKey + "已经被屏蔽！", "警告", MessageBoxButtons.OK, MessageBoxIcon.Error);}}}catch (Exception ex){MessageBox.Show("错误：" + ex.ToString(), "警告", MessageBoxButtons.OK, MessageBoxIcon.Error);AddLog(dicSockets[strKey].RemoteEndPoint.ToString() + "客户端已断开连接,无法发送信息！");}}private void button2_Click(object sender, EventArgs e){listBox2.Items.Clear(); }private void button3_Click(object sender, EventArgs e){string copystr;copystr = "";for (int i = 0; i <= listBox2.Items.Count - 1; i++){copystr = copystr + (string)listBox2.Items[i] + "\r\n";}Clipboard.Clear();Clipboard.SetDataObject(copystr);MessageBox.Show("显示的数据报文已拷贝到剪切板", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);}private void button4_Click(object sender, EventArgs e){AddLog("接收线程数量：" + dicThreads.Count.ToString());}private void button5_Click(object sender, EventArgs e){//1.没有选择退出if (listBox1.SelectedIndex == -1){MessageBox.Show("请选择要断开的客户端！","警告", MessageBoxButtons.OK, MessageBoxIcon.Error);return;}//2.切断客户端的连接 string RemoteEndPointStr = listBox1.SelectedItem.ToString();AddLog("强制断开客户端" + RemoteEndPointStr + "的连接！");listBox1.SelectedIndex = -1;Socket disconnSocket = dicSockets[RemoteEndPointStr];disconnSocket.Close();}//解析接收到的数据信息，并回应驱动读卡器显示文字、蜂鸣响声、播报语音、开关继电器等private void AnalyticGetData(byte[] getdata, int length, string IPort){string msginf = "";uint cardhao;string cardnumberstr = "";switch (getdata[0]){case 0xc1: //接收到IC读卡器读取的卡号case 0xcf: //接收到IC离开读卡器if (getdata[0] == 0xc1){msginf = "数据解析：IC读卡器刷卡数据";}else { msginf = "数据解析：IC卡离开读卡器"; }msginf = msginf + "，IP[" + getdata[1].ToString() + "." + getdata[2].ToString() + "." + getdata[3].ToString() + "." + getdata[4].ToString();msginf = msginf + "，机号[" + Convert.ToString(getdata[5] + getdata[6] * 256) + "]，数据包序号[" + Convert.ToString(getdata[7] + getdata[8] * 256) + "]，卡号长度[" + Convert.ToString(getdata[9]) + "]，16进制卡号[";for (int i = 10; i < 10 + getdata[9]; i++){msginf = msginf + getdata[i].ToString("X2");}cardhao = (uint)(getdata[13] * 256 * 256 * 256 + getdata[12] * 256 * 256 + getdata[11] * 256 + getdata[10]);cardnumberstr = "0000000000" + Convert.ToString(cardhao);//卡号cardnumberstr = cardnumberstr.Substring(cardnumberstr.Length - 10, 10);msginf = msginf + "]，转10进制卡号[" + cardnumberstr;msginf = msginf + "]，唯一设备序号[";for (int i = 10 + getdata[9]; i < length; i++){msginf = msginf + getdata[i].ToString("X2");}msginf = msginf + "]";AddLog(msginf);AddLog("");Response(IPort);break;case 0xd1: //接收到ID读卡器读取的卡号case 0xdf: //接收到ID卡离开读卡器if (getdata[0] == 0xd1){msginf = "数据解析：ID读卡器刷卡数据";}else { msginf = "数据解析：ID卡离开读卡器"; }msginf = msginf + "，IP[" + getdata[1].ToString() + "." + getdata[2].ToString() + "." + getdata[3].ToString() + "." + getdata[4].ToString();msginf = msginf + "，机号[" + Convert.ToString(getdata[5] + getdata[6] * 256) + "]，数据包序号[" + Convert.ToString(getdata[7] + getdata[8] * 256) + "]";cardhao = (uint)(getdata[12] * 256 * 256 * 256 + getdata[11] * 256 * 256 + getdata[10] * 256 + getdata[9]);cardnumberstr = "0000000000" + Convert.ToString(cardhao);//卡号cardnumberstr = cardnumberstr.Substring(cardnumberstr.Length - 10, 10);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 + "]";msginf = msginf + "，唯一设备序号[";for (int i = 14; i < length; i++){msginf = msginf + getdata[i].ToString("X2");}msginf = msginf + "]";AddLog(msginf);AddLog("");Response(IPort);break;case 0xf3: //接收到读卡器心跳包msginf = "数据解析：读卡器读卡器心跳包，IP[" + getdata[1].ToString() + "." + getdata[2].ToString() + "." + getdata[3].ToString() + "." + getdata[4].ToString();msginf = msginf + "，机号[" + Convert.ToString(getdata[5] + getdata[6] * 256) + "]，数据包序号[" + Convert.ToString(getdata[7] + getdata[8] * 256) + "]，心跳包类型[" + Convert.ToString(getdata[9]) + "]";msginf = msginf + "，长度[" + Convert.ToString(getdata[10]) + "]";msginf = msginf + "，继电器状态[" + getdata[11].ToString("X2") + "]";msginf = msginf + "，外部输入状态[" + getdata[12].ToString("X2") + "]";msginf = msginf + "，随机动态码[" + getdata[13].ToString("X2") + getdata[14].ToString("X2") + getdata[15].ToString("X2") + getdata[16].ToString("X2") + "]";for (int i = 17; i < length; i++){msginf = msginf + getdata[i].ToString("X2");}msginf = msginf + "]";AddLog(msginf);AddLog("");break;}}//回应读卡器驱动显示文字、蜂鸣响声、播报语音等private void Response(string IPort){byte[] databuf = new byte[280];int i;int dispbytes; //显示文字节数int speakbytes; //语音播报字节表int sendbytes; //报文数据长度 dispbytes = 34; //双行屏34，四行屏72显示长度，如不显示文字可以为0string strls = "[v";if (SYDX.Value <= 16){strls = strls + (SYDX.Value.ToString()).Trim() + "]"; //设置语音大小，在需要发送的语音字符串中任何位置加入[v10],表示将音量调到10级(范围0~16，0表示静音，16最大，每次重开机后，音量重置为10级)！}else { strls = strls + "16]"; }strls = strls + textBox12.Text.Trim();byte[] SpeakArr = System.Text.Encoding.GetEncoding(936).GetBytes(strls);//TTS语音转换为Ansispeakbytes = SpeakArr.GetLength(0); //语音长度sendbytes = 11 + dispbytes + speakbytes + 4; //总计发送数据长度databuf[0] = 0x5C; //表示驱动蜂鸣器+TTS组合语音+显示文字+继电器databuf[1] = 0; //机号低位,databuf[2] = 0; //机号高位，如果高低位都为0表示任意机号，TCP是点对点通讯if (checkBox2.Checked) //可以同时发出声响{databuf[3] = (byte)(comboBox3.SelectedIndex);if (radioButton2.Checked) //背光灯不变{databuf[3] = (byte)(databuf[3] | 0x80);}}else{databuf[3] = 0xff;//不发出声响if (radioButton2.Checked) //背光灯不变{databuf[3] = (byte)(databuf[3] & 0x80);}}switch (comboBox2.SelectedIndex) //继电器{case 1:databuf[4] = 0xF1;break;case 2:databuf[4] = 0xF2;break;case 3:databuf[4] = 0xF3;break;case 4:databuf[4] = 0xF4;break;case 5:databuf[4] = 0xF5;break;case 6:databuf[4] = 0xF6;break;case 7:databuf[4] = 0xF7;break;case 8:databuf[4] = 0xF8;break;default:databuf[4] = 0xF0;break;}i = Convert.ToInt32(textBox11.Text); //继电器时长databuf[5] = (byte)(i % 256);databuf[6] = (byte)(i / 256);databuf[7] = (byte)(numericUpDown1.Value);//显示保留时间，单位为秒，为255时表示永久显示databuf[8] = 0; //在显示屏中的哪个位置开始databuf[9] = (byte)dispbytes; //显示字符串长度 0-34为全屏databuf[10] = (byte)speakbytes; //TTS语音长度strls = textBox12.Text + " ";byte[] strlsansi = System.Text.Encoding.GetEncoding(936).GetBytes(strls);//显示文字转换为Ansifor (i = 0; i < speakbytes; i++){databuf[11 + i] = (Byte)strlsansi[i];}for (i = 0; i < speakbytes; i++) //连播语音代码{databuf[11 + databuf[9] + i] = (Byte)SpeakArr[i];}databuf[10 + databuf[9] + speakbytes + 1] = 0x55; //防干扰后缀databuf[10 + databuf[9] + speakbytes + 2] = 0xAA;databuf[10 + databuf[9] + speakbytes + 3] = 0x66;databuf[10 + databuf[9] + speakbytes + 4] = 0x99;int sendlen = 10 + databuf[9] + speakbytes + 5;byte[] sendbuf = new byte[sendlen];string dispstr = DateTime.Now.ToString("hh:mm:ss.fff") + " SendTo " + IPort + " ：";for (i = 0; i < sendlen; i++) //连播语音代码{sendbuf[i] = databuf[i];dispstr = dispstr + databuf[i].ToString("X2") + " ";}dicSockets[IPort].Send(sendbuf);AddLog(dispstr);AddLog(" ");}private void button6_Click(object sender, EventArgs e){byte[] sendbuf = new byte[4];sendbuf[0] = 0x96; //声响指令sendbuf[1] = 0; //机号低位,sendbuf[2] = 0; //机号高位，如果高低位都为0表示任意机号，TCP是点对点通讯sendbuf[3] = (byte)(comboBox3.SelectedIndex);ServerSingSenddata(sendbuf);}private void button7_Click(object sender, EventArgs e){byte[] sendbuf = new byte[6];sendbuf[0] = 0x78; //继电器指令sendbuf[1] = 0; //机号低位,sendbuf[2] = 0; //机号高位，如果高低位都为0表示任意机号，TCP是点对点通讯switch (comboBox2.SelectedIndex){case 1:sendbuf[3] = 0xF1;break;case 2:sendbuf[3] = 0xF2;break;case 3:sendbuf[3] = 0xF3;break;case 4:sendbuf[3] = 0xF4;break;case 5:sendbuf[3] = 0xF5;break;case 6:sendbuf[3] = 0xF6;break;case 7:sendbuf[3] = 0xF7;break;case 8:sendbuf[3] = 0xF8;break;default:sendbuf[3] = 0xF0;break;}int i = Convert.ToInt32(textBox11.Text);//延时sendbuf[4] = (byte)(i % 256);sendbuf[5] = (byte)(i / 256);ServerSingSenddata(sendbuf);}private void button8_Click(object sender, EventArgs e){byte[] sendbuf = new byte[6];sendbuf[0] = 0x78; //继电器指令sendbuf[1] = 0; //机号低位,sendbuf[2] = 0; //机号高位，如果高低位都为0表示任意机号，TCP是点对点通讯switch (comboBox2.SelectedIndex){case 1:sendbuf[3] = 0xE1;break;case 2:sendbuf[3] = 0xE2;break;case 3:sendbuf[3] = 0xE3;break;case 4:sendbuf[3] = 0xE4;break;case 5:sendbuf[3] = 0xE5;break;case 6:sendbuf[3] = 0xE6;break;case 7:sendbuf[3] = 0xE7;break;case 8:sendbuf[3] = 0xE8;break;default:sendbuf[3] = 0xE0;break;}int i = Convert.ToInt32(textBox11.Text);//延时sendbuf[4] = (byte)(i % 256);sendbuf[5] = (byte)(i / 256);ServerSingSenddata(sendbuf);}private void button10_Click(object sender, EventArgs e){string strls;byte[] sendbuf = new byte[39];int i;sendbuf[0] = 0x5a; //显示文字的指令sendbuf[1] = 0; //机号低位,sendbuf[2] = 0; //机号高位，如果高低位都为0表示任意机号，TCP是点对点通讯if (checkBox2.Checked) //可以同时发出声响{sendbuf[3] = (byte)(comboBox3.SelectedIndex);if (radioButton2.Checked) //背光灯不变{sendbuf[3] = (byte)(sendbuf[3] | 0x80);}}else{sendbuf[3] = 0xff;//不发出声响if (radioButton2.Checked) //背光灯不变{sendbuf[3] = (byte)(sendbuf[3] & 0x80);}}sendbuf[4] = (byte)(numericUpDown1.Value);//显示保留时间，单位为秒，为255时表示永久显示strls = textBox12.Text + " ";byte[] strlsansi = System.Text.Encoding.GetEncoding(936).GetBytes(strls);//转换为Ansi //显示文字的ASCII码for (i = 0; i < 34; i++){sendbuf[5 + i] = (Byte)strlsansi[i];}ServerSingSenddata(sendbuf); }private void button9_Click(object sender, EventArgs e){byte[] databuf = new byte[280];int i;int dispbytes; //显示文字节数int speakbytes; //语音播报字节表int sendbytes; //报文数据长度 dispbytes = 34; //双行屏34，四行屏72显示长度，如不显示文字可以为0string strls = "[v";if (SYDX.Value <= 16){strls = strls + (SYDX.Value.ToString()).Trim() + "]"; //设置语音大小，在需要发送的语音字符串中任何位置加入[v10],表示将音量调到10级(范围0~16，0表示静音，16最大，每次重开机后，音量重置为10级)！}else { strls = strls + "16]"; }strls = strls + textBox12.Text.Trim();byte[] SpeakArr = System.Text.Encoding.GetEncoding(936).GetBytes(strls);//TTS语音转换为Ansispeakbytes = SpeakArr.GetLength(0); //语音长度sendbytes = 11 + dispbytes + speakbytes + 4; //总计发送数据长度databuf[0] = 0x5C; //表示驱动蜂鸣器+TTS组合语音+显示文字+继电器databuf[1] = 0; //机号低位,databuf[2] = 0; //机号高位，如果高低位都为0表示任意机号，TCP是点对点通讯if (checkBox2.Checked) //可以同时发出声响{databuf[3] = (byte)(comboBox3.SelectedIndex);if (radioButton2.Checked) //背光灯不变{databuf[3] = (byte)(databuf[3] | 0x80);}}else{databuf[3] = 0xff;//不发出声响if (radioButton2.Checked) //背光灯不变{databuf[3] = (byte)(databuf[3] & 0x80);}}switch (comboBox2.SelectedIndex) //继电器{case 1:databuf[4] = 0xF1;break;case 2:databuf[4] = 0xF2;break;case 3:databuf[4] = 0xF3;break;case 4:databuf[4] = 0xF4;break;case 5:databuf[4] = 0xF5;break;case 6:databuf[4] = 0xF6;break;case 7:databuf[4] = 0xF7;break;case 8:databuf[4] = 0xF8;break;default:databuf[4] = 0xF0;break;}i = Convert.ToInt32(textBox11.Text); //继电器时长databuf[5] = (byte)(i % 256);databuf[6] = (byte)(i / 256);databuf[7] = (byte)(numericUpDown1.Value);//显示保留时间，单位为秒，为255时表示永久显示databuf[8] = 0; //在显示屏中的哪个位置开始databuf[9] = (byte)dispbytes; //显示字符串长度 0-34为全屏databuf[10] = (byte)speakbytes; //TTS语音长度strls = textBox12.Text + " ";byte[] strlsansi = System.Text.Encoding.GetEncoding(936).GetBytes(strls);//显示文字转换为Ansifor (i = 0; i < speakbytes; i++){databuf[11 + i] = (Byte)strlsansi[i];}for (i = 0; i < speakbytes; i++) //连播语音代码{databuf[11 + databuf[9] + i] = (Byte)SpeakArr[i];}databuf[10 + databuf[9] + speakbytes + 1] = 0x55; //防干扰后缀databuf[10 + databuf[9] + speakbytes + 2] = 0xAA;databuf[10 + databuf[9] + speakbytes + 3] = 0x66;databuf[10 + databuf[9] + speakbytes + 4] = 0x99;int sendlen = 10 + databuf[9] + speakbytes + 5;byte[] sendbuf = new byte[sendlen];for (i = 0; i < sendlen; i++) //连播语音代码{sendbuf[i] = databuf[i];}ServerSingSenddata(sendbuf); }private void comboBox4_SelectedIndexChanged(object sender, EventArgs e){try{ listenSocket.Close();//关闭监听套接字，并释放listenThread.Abort();//强行中断AddLog("结束监听客户端传来的信息!");AddLog("关闭服务器，断开所有客户端用户的连接!");//切断所有客户端的连接for (int i = 0; i < listBox1.Items.Count; i++){string str = listBox1.Items[i].ToString();Socket m_socket = dicSockets[str];m_socket.Close();}btn_conn.Text = "开启服务器"; }catch (Exception f){btn_conn.Text = "开启服务器";}}private void Form13_FormClosed(object sender, FormClosedEventArgs e){try{listenSocket.Close();//关闭监听套接字，并释放listenThread.Abort();//强行中断AddLog("结束监听客户端传来的信息!");AddLog("关闭服务器，断开所有客户端用户的连接!");//切断所有客户端的连接for (int i = 0; i < listBox1.Items.Count; i++){string str = listBox1.Items[i].ToString();Socket m_socket = dicSockets[str];m_socket.Close();}btn_conn.Text = "开启服务器";}catch (Exception f){btn_conn.Text = "开启服务器";}}}
}