[网络协议]TCP服务器

TCP服务器

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using _0709_综合项目.FormAll;
using HalconDotNet;

namespace _0709_综合项目
{
    public class tcpServer
    {
        #region 通讯
        Socket _Seriver;
        public static Socket ClientSocket;
        Thread rec;
        Thread th;
        public static bool isSend;
        public static string strSend;
        bool isOpen = false;
        byte[] buffer = new byte[1024 * 1024];
        /// 启动服务
        public void StarSer(string tb_IP,string tb_Port)
        {
            if (!isOpen)
            {
                IPAddress IP = IPAddress.Parse(tb_IP);
                //1.初始化套接字
                _Seriver = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                //2.绑定IP和端口号
                _Seriver.Bind(new IPEndPoint(IP, int.Parse(tb_Port)));
                //3.监听
                _Seriver.Listen(10);
                //4.开启线程监听
                th = new Thread(new ThreadStart(ListenThread));
                th.IsBackground = true;
                th.Start();
                isOpen = true;
            }
            else//关闭服务
            {
                if (_Seriver != null)
                {
                    _Seriver.Close();
                }
                if (ClientSocket != null)
                {
                    ClientSocket.Close();
                }
                isOpen = false;
            }
        }
        // 监听线程 子线程入口
        public void ListenThread()
        {
            try
            {
                while (true)
                {
                    //5.等待客户请求 （没请求 阻塞）  第二个套接字
                    ClientSocket = _Seriver.Accept();//阻塞
                    isSend = true;
                    strSend = "连接成功！";
                    //Invoke(new MethodInvoker(() => {
                    //    lb_Rec.Items.Add("连接成功！");
                    //}));
                    //6.开启接收线程
                    rec = new Thread(new ParameterizedThreadStart(RecDataThread));
                    rec.IsBackground = true;
                    rec.Start(ClientSocket);
                }
            }
            catch (Exception) { }
        }
        //接收数据线程
        public void RecDataThread(object obj)
        {
            try
            {
                Socket _socketClient = (Socket)obj;
                while (true)
                {
                    //7.接收数据
                    int counts = _socketClient.Receive(buffer);
                    if (counts > 0)
                    {
                        string str = Encoding.Default.GetString(buffer, 0, counts);
                        //显示（字符串）
                        //Invoke(new MethodInvoker(() =>
                        //{
                        //    lb_Rec.Items.Add(string.Format("{0}：{1}", _socketClient, str));
                        //}));
                        isSend = true;
                        strSend = str;
                        if (str.Substring(0, 2) == "OK")
                        {
                            Position.MRE.Set();
                            Fit.MRE1.Set();
                            Fit.MRE2.Set();
                            Fit.MRE3.Set();
                            MoveCam.MREMove.Set();
                            Calibration.MREcalib.Set();
                            Correction.MREDown.Set();
                        }
                    }
                }
            }
            catch (Exception) { }
        }
        //发送字符串 不加校验
        public void sendData(string str )
        {
                byte[] buffer = Encoding.Default.GetBytes(str);
                ClientSocket.Send(buffer);
        }
        #endregion
    }
}