c# - 在 .net 4 下开发具有同步和异步功能的 TCP 客户端,该客户端还监听服务器发起的通知

标签 c# .net visual-studio-2010 tcpclient

我在c#中的.net4下通过异步模式开发了一个TCP服务器,它可以同时处理数百个TCP连接。它已经工作了几个月没有任何问题,所以,我有异步套接字等方面的经验。在.net中。

现在我有另一个项目:这次我必须开发一个 TCP 客户端,它通过 TCP 连接到服务器(一个且唯一的服务器,而不是更多!)并向其发送命令,获取响应并处理传入的服务器发起通知消息。

现在我有点困惑。我正在寻找实现这些功能的最有效方法:

  • 它必须异步发送一些命令并异步获取它们的响应
  • 一些命令应该同步发送并同步获取响应
  • 它必须监听传入的通知 TCP 消息。因此,这些消息是从服务器端发起的,它们并不是作为请求的响应

您认为哪种模式是实现它的最佳模式?如何监听传入的服务器发起的请求,同时处理客户端发起的请求?

谢谢!

索取 sample :

02/00059/O/60/07656765/2/1/1/50617373776F7264//0100//////61 

响应示例:

00/00019/R/60/A//6D 

通知示例: 00/00114/O/52/0011456046589/01123404543////////////0000/568112131424////3//43424‌1///0//////56312389921/020100///C3

最佳答案

这实际上取决于服务器如何格式化传入的命令。例如,它们采用“”形式。

我要做的第一件事是编写一个套接字类,用于处理读取数据并为收到的每个“行”引发一个事件(例如,OnLine)(这只是一个示例,我有不知道您的命令和消息的格式是什么)。

然后,我将实现一个将此文本套接字作为成员的类,并订阅收到的事件行。这个类还有一个委托(delegate)字典,映射到可以从服务器接收的可能命令,例如:

public class MyClient
{
    private delegate void CommandHandler(string data);
    private TextSocket socket_ = new TextSocket(); // text socket we created

    private Dictionary<string, CommandHandler> cmdMap_ = new Dictionary<string, CommandHandler>();

    public MyClient()
    {
        // Initialise our map full of delegates
        cmdMap_["CMD1"] = (data) => { /* handle this command */ };
        cmdMap_["CMD2"] = (data) => { /* handler for this one */ };

        socket_.OnLineReceived += (line) 
        {
            if(!string.IsNullOrEmpty(line)) // sanity check
            {
                string cmd;
                string data;
                int pos = line.IndexOf(' ');
                if(pos != -1)
                {
                    cmd = line.Substring(0, pos);
                    data = line.Substring(pos + 1);
                }
                else
                    cmd = line;

                if(cmdMap_.ContainsKey(cmd))
                    cmdMap_[cmd](data);
            }
        }; 
    }
}

注意,我在这里使用了 lambda,但肯定不需要。

关于c# - 在 .net 4 下开发具有同步和异步功能的 TCP 客户端,该客户端还监听服务器发起的通知,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/9719582/

相关文章:

c# - C#如何计算sql表的行数?

c# - PCL Profile 158 中的 Async/await 也针对 Android 和 IOS

c# - 来自 IIS 中托管的网站的 SOAP API 访问错误

.net - 在 C# 上编译 C++ 应用程序

c# - 'Microsoft.Jet.OLEDB.4.0' 提供者未在本地机器上注册

visual-studio-2010 - 更改 VS2010 起始页上显示的最近项目的数量

c# - 如何设置 CultureInfo.CurrentCulture?

c# - 为什么当 Assembly 在 CurrentDomain 中时会调用 AssemblyResolve?

visual-c++ - 制作一个简单的应用程序,使用 Visual Studio 2010 Express、google glog 和 google gflags 记录和读取命令行参数?

c++ - Visual Studio 2010 中是否有 64 位的#define?