Code Bye

C# TCP 一个客户端对应多台服务器 多线程问题求解

码拜
多线程
tcp
c#

– – 本来一直在做交通智能仿真产品，结果中途来了一个插曲，目前需求就是这样的，由于现场网络环境局限，是公安网，有很多台设备只能将模式设置为服务端，那么我要编写一个TCP客户端程序，去接收每一台设备的数据，然后解析处理存入数据库,我用TCP异步的方式实现了该功能，但是发现异步也有异步的缺点，所以我想多线程+同步接收的方式来实现以后做一个对比，稳定性或者效率等等。下面是我连接一台设备服务器的代码，我想知道，如果是多台，我该如何修改以下代码，以实现接受处理多台服务器的数据？谢谢！

 /// <summary>
        /// 程序开始
        /// </summary>
        public static void StartMain()
        {
            try
            {
                ByteQueue queue = new ByteQueue();
                int port = 4001;
                string host = "192.168.0.81";
                IPAddress ip = IPAddress.Parse(host);
                IPEndPoint ipe = new IPEndPoint(ip, port);
                Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                socket.Connect(ipe);

                while (true)
                {
                    //建立缓冲区
                    byte[] recByte = new byte[4096];
                    int bytes = socket.Receive(recByte, recByte.Length, 0);

                    //分多次接收
                    byte[] reallData = new byte[bytes];
                    Array.Copy(recByte, reallData, reallData.Length);
                    queue.Enqueue(reallData);

                    //while可处理同时接收到多个包 防止一帧数据不是完整的包  
                    while (queue.Find())
                    {
                        byte[] readBuffer = queue.Dequeue();

                        //解析雷达数据 包含平均速度/占有率/车流量
                        string data = BitConverter.ToString(readBuffer);
                        if (data.StartsWith("FF-FF-FF-FF-CA-CB-CC-CD") && data.EndsWith("EA-EB-EC-ED"))
                        {
                            string repStr = data.Replace("-", " ");
                            Regex regex = new Regex("07 81 08.{24}");
                            MatchCollection matches = regex.Matches(repStr, 0);

                            //判断是否是统计数据
                            if (matches.Count > 0)
                            {
                                List<T_RadarStatistics> statisticsList = HandleStatisticsData(repStr, host);

                                foreach (var item in statisticsList)
                                {
                                    StringBuilder builder = new StringBuilder();
                                    //builder.AppendFormat("\n    地址：{0}：{1} ", ip, port);
                                    builder.Append("\n    时间： " + DateTime.Now);
                                    builder.Append("\n    测量线： " + item.Measureline);
                                    builder.Append("\n    车道： " + item.StatisLlane);
                                    builder.Append("\n    平均车速： " + item.SumAvspeed);
                                    builder.Append("\n    时间占有率： " + item.SumOccupancy);
                                    builder.Append("\n    车流量： " + item.SumVolume);
                                    builder.Append("\n    车头实距： " + item.HeadWay);
                                    builder.Append("\n----------------------------------------------------------");
                                    Console.WriteLine(builder.ToString());
                                }
                            }
                        }
                    }
                }
            }
            catch (ArgumentNullException e)
            {
                //MessageBox.Show("ArgumentNullException: {0}", e.Message);
            }
            catch (SocketException e)
            {
                //MessageBox.Show("SocketException: {0}", e.Message);
            }
        }
服务端不会主动地向客户端发送数据，因为他并不知道客户端是否存在
所以通讯过程是客户端向服务端发送请求后，才能接收到服务端发回的数据
你使用异步方式是很科学的，因为等待数据回传是不占用系统资源的
你若改成同步方式，那么势必需要构建一个持久的循环，不断地检查数据传输是否结束
引用 1 楼 xuzuning 的回复:

服务端不会主动地向客户端发送数据，因为他并不知道客户端是否存在
所以通讯过程是客户端向服务端发送请求后，才能接收到服务端发回的数据
你使用异步方式是很科学的，因为等待数据回传是不占用系统资源的
你若改成同步方式，那么势必需要构建一个持久的循环，不断地检查数据传输是否结束

首先谢谢您的回答，但是目前的情况就是，一旦设备设置成Server模式，那么只要我这边客户端连接成功，就可以获取数据了。这个不用考虑。现在就是想用多线程+同步的方式实现看看。
引用 楼主 SomethingJack 的回复:

– – 本来一直在做交通智能仿真产品，结果中途来了一个插曲，目前需求就是这样的，由于现场网络环境局限，是公安网，有很多台设备只能将模式设置为服务端，那么我要编写一个TCP客户端程序，去接收每一台设备的数据，然后解析处理存入数据库,我用TCP异步的方式实现了该功能，但是发现异步也有异步的缺点，所以我想多线程+同步接收的方式来实现以后做一个对比，稳定性或者效率等等。下面是我连接一台设备服务器的代码，我想知道，如果是多台，我该如何修改以下代码，以实现接受处理多台服务器的数据？谢谢！

把你的方法 StartMain() 修改为 

 public static void StartMain(string host, int port)
{
    .....

同时检查一遍、方法里不应该乱用其它“共享变量”。
然后在主程序中写

var clientHostList = new string[ ]{"192.168.0.81"};
var port = 12345;
foreach(string host in clientHostList)
{
    var h = host;
    ThreadPool.QueueUserWorkItem(h=> StartMain(h, port));
}
嗯，变量命名有重复，应该编译不过去。把变量命名改一下，例如 
foreach(string host in clientHostList)
{
    var svr = host;
    ThreadPool.QueueUserWorkItem(h=> StartMain(svr, port));
}
我擦又是你?
下位机客户端做模拟就好做了.. 
 byte[] buffer = new byte[1024];
 Socket socket;

连接很简单

socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
socket.Connect(txt_ip.Text, int.Parse(txt_port.Text));

然后丢一个这个就好了

 socket.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveMessage), socket);

当然实现的方式是这样的.

 void ReceiveMessage(IAsyncResult ar)
{
                var socket = ar.AsyncState as Socket;
                var length = socket.EndReceive(ar);
                byte[] reallData = new byte[length];
                Array.Copy(buffer, reallData, length);
                var abc=string.Join("-", reallData.Select(d => d.ToString("X2")).ToArray());
                 //处理
         socket.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveMessage), socket);
}
楼上的- – 我异步的方法做好了 你这个是异步的方式 我知道 我现在想要利用多线程+同步的方式 
引用 4 楼 sp1234 的回复:

嗯，变量命名有重复，应该编译不过去。把变量命名改一下，例如

foreach(string host in clientHostList)
{
    var svr = host;
    ThreadPool.QueueUserWorkItem(h=> StartMain(svr, port));
}

我刚才试了一下 这样子 我调试的时候就没法获得主线程的数据过来了  调试到以下这一步 就无法进行调试了 在main函数中调用的

 ByteQueue queue = new ByteQueue();
                IPAddress ip = IPAddress.Parse(host);
                IPEndPoint ipe = new IPEndPoint(ip, port);
客户端，特别是短连接的客户端，用不着异步处理。

你的方法要能够“只写一份”而启动上百个线程调用它，所需要变化的参数设备的host和port。除了参数，其它部分应该保持你的 StartMain 方法的基本不变。
现在改成这样，但是CMD窗口 直接任何反应都没有了 调试也没有调试进去，这个应该是多线程问题，这个我该怎么获取数据了- – 
static void Main(string[] args)
        {
            var clientHostList = new string[] { "192.168.0.81", "192.168.0.87" };
            var port = 4001;
            foreach (string host in clientHostList)
            {
                var svr = host;
                ThreadPool.QueueUserWorkItem(h => StartMain(svr, port));
            }
        }

        /// <summary>
        /// 程序开始
        /// </summary>
        public static void StartMain(string host, int port)
        {
            try
            {
                ByteQueue queue = new ByteQueue();
                IPAddress ip = IPAddress.Parse(host);
                IPEndPoint ipe = new IPEndPoint(ip, port);
                Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                socket.Connect(ipe);
                if (socket.Connected)
                {
                    Console.WriteLine(ip + " Connected......");
                }
                while (true)
                {
                    //建立缓冲区
                    byte[] recByte = new byte[4096];
                    int bytes = socket.Receive(recByte, recByte.Length, 0);

                    //分多次接收
                    byte[] reallData = new byte[bytes];
                    Array.Copy(recByte, reallData, reallData.Length);
                    queue.Enqueue(reallData);

                    //while可处理同时接收到多个包 防止一帧数据不是完整的包  
                    while (queue.Find())
                    {
                        byte[] readBuffer = queue.Dequeue();

                        //解析雷达数据 包含平均速度/占有率/车流量
                        string data = BitConverter.ToString(readBuffer);
                        if (data.StartsWith("FF-FF-FF-FF-CA-CB-CC-CD") && data.EndsWith("EA-EB-EC-ED"))
                        {
                            string repStr = data.Replace("-", " ");
                            Regex regex = new Regex("07 81 08.{24}");
                            MatchCollection matches = regex.Matches(repStr, 0);

                            //判断是否是统计数据
                            if (matches.Count > 0)
                            {
                                List<T_RadarStatistics> statisticsList = HandleStatisticsData(repStr, host);

                                foreach (var item in statisticsList)
                                {
                                    StringBuilder builder = new StringBuilder();
                                    builder.AppendFormat("\n    地址：{0}：{1} ", ip, port);
                                    builder.Append("\n    时间： " + DateTime.Now);
                                    builder.Append("\n    测量线： " + item.Measureline);
                                    builder.Append("\n    车道： " + item.StatisLlane);
                                    builder.Append("\n    平均车速： " + item.SumAvspeed);
                                    builder.Append("\n    时间占有率： " + item.SumOccupancy);
                                    builder.Append("\n    车流量： " + item.SumVolume);
                                    builder.Append("\n    车头实距： " + item.HeadWay);
                                    builder.Append("\n----------------------------------------------------------");
                                    Console.WriteLine(builder.ToString());
                                }
                            }
                        }
                    }
                }
            }
            catch (ArgumentNullException e)
            {
                //MessageBox.Show("ArgumentNullException: {0}", e.Message);
            }
            catch (SocketException e)
            {
                //MessageBox.Show("SocketException: {0}", e.Message);
            }
        }
使用  HttpListener 可以同时监听多个端口，很方便。

                ThreadPool.SetMaxThreads(100,100);
                _invoiceForRZForm = new CommonInvoiceForRZForm();
                _listener = new HttpListener();
                _listener.Prefixes.Add(string.Format(“http://{0}/”, prientServiceUrl)); //添加需要监听的url范围，Prefixes可添加多个
                _listener.Start(); //开始监听端口，接收客户端请求
                _threadWatchPort = new Thread(WatchPort);
                _threadWatchPort.Start();

sp大神送佛送到西- – 哈哈
100分
引用 10 楼 SomethingJack 的回复:

现在改成这样，但是CMD窗口 直接任何反应都没有了 调试也没有调试进去，这个应该是多线程问题，这个我该怎么获取数据了- –

CMD窗口？难道你贴出顶楼问题时其实是没有跑起来的？你在顶楼的程序怎样跑起来的，现在不用做任何改动！只不过把原来调用 StartMain() 的那一行代码修改一下啊。

唉！如果你一定要使用 CMD 窗口老来测试的话，好歹要在最后写一行 Console.ReadLine() 之类的话啊。不然 CMD 窗口进程直接就结束了嘛。

而这种程序我相信通常是跑在你的桌面（例如winform）程序中的，要在一个窗体中去实时显示每一个设备的通讯状态（至少你要给人家显示几排黄绿灯图标）啊。
CodeBye 版权所有丨如未注明 , 均为原创丨本网站采用BY-NC-SA协议进行授权 , 转载请注明C# TCP 一个客户端对应多台服务器 多线程问题求解！