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

.Net技术 码拜 6年前 (2015-05-10) 446次浏览 0个评论

– – 本来一直在做交通智能仿真产品,结果中途来了一个插曲,目前需求就是这样的,由于现场网络环境局限,是公安网,有很多台设备只能将模式设置为服务端,那么我要编写一个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 一个客户端对应多台服务器 多线程问题求解
喜欢 (0)
[1034331897@qq.com]
分享 (0)

文章评论已关闭!