如何处理一些异步TcpClient响应？

Question

萨拉姆.

我在我的项目中使用此类进行异步客户端 - 服务器TCP网络连接(https://github.com/Phyyl/ObooltNet/blob/master/Source/ObooltNet/NetConnection.cs).

我大多数连接到" Remote server"并通过TCP连接发送和接收数据(来自另一家我们无法更改除TCP之外的通信方法的公司)" Interface Web Service".

这个" Interface Web Service"句柄" Client Apps" Remote server通过TCP连接请求,创建数据并传递给" ",并将解析后的响应" Remote server"传递给" Client Apps".

注意当前的TCP连接,接收Remote server带有OnDataReceived事件的响应.(此事件很好,我想将此事件用于后续步骤).

如何访问和处理这些异步响应并传递" Client Apps"请求的完整响应？

总结一下:

1. Client app 发送请求 Interface service
2. Interface service 为...创建命令 Remote server
3. Remote server 响应命令来自 Interface service
4. 现在Interface service,使用OnDataReceivedEVENT 处理响应,我无法从Interface service该句柄Client App请求访问它.问题在这里......

---

查看此图像以完成了解我的场景:

Answer 1

请查看该课程的以下完整(但不是最佳)工作样本.

注意方法中的while循环MyHandler.ProcessRequest.

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Web;
using System.Threading.Tasks;

namespace TestApp
{
    class Program
    {

        private static NetConnection fakeServerConnector { get; set; }

        static void Main(string[] args)
        {
            var pageHandler = new MyHandler();
            var tw = Console.Out;
            var builder = new UriBuilder();
            builder.Host = "localhost";
            builder.Port = 80;
            builder.Query = "";

            initFakeServer(8080);

            pageHandler.ProcessRequest(
                new HttpContext(
                    new HttpRequest("index.html", builder.ToString(), ""),
                    new HttpResponse(tw))
                    );

            ConsoleKey key;
            Console.WriteLine(Environment.NewLine + "Press [Enter] or [Esc] to exit!");
            do
            {
                key = Console.ReadKey().Key;
            } while (!(key == ConsoleKey.Enter || key == ConsoleKey.Escape));
        }

        private static void initFakeServer(int Port)
        {
            fakeServerConnector = new NetConnection();
            fakeServerConnector.OnDataReceived += fakeServerConnector_OnDataReceived;
            fakeServerConnector.Start(Port);

        }

        static void fakeServerConnector_OnDataReceived(object sender, NetConnection connection, byte[] e)
        {
            Console.WriteLine(System.Text.UTF8Encoding.UTF8.GetString(e));
            var msg = System.Text.UTF8Encoding.UTF8.GetBytes("Fake Server says: \"Hi\"");
            connection.Send(msg);
        }
    }

    public class MyHandler : IHttpHandler
    {

        public string HostName { get; set; }
        public int Port { get; set; }
        private NetConnection clientConnector { get; set; }
        private bool isReceived;
        private byte[] responsePayload;

        public bool IsReusable
        {
            get { return false; }
        }



        public void ProcessRequest(HttpContext context)
        {            
            HostName = "localhost";
            Port = 8080;

            clientConnector = new NetConnection();
            clientConnector.OnDataReceived += OnDataReceivedHandler;
            clientConnector.Connect(HostName, Port);
            clientConnector.Send(System.Text.UTF8Encoding.UTF8.GetBytes("Client Connector says: \"Hello World\""));
            while (!isReceived)
            {
                // do nothing; wait for isReceived to become true;
            }
            var responsePayloadText = System.Text.ASCIIEncoding.UTF8.GetString(responsePayload, 0, responsePayload.Length);
            context.Response.Write(responsePayloadText + Environment.NewLine);
        }


        public void OnDataReceivedHandler(object sender, NetConnection connection, byte[] data)
        {
            isReceived = true;
            responsePayload = data;
        }
    }    
}

Answer 2

感谢您阅读并尽力帮助我.

我通过编辑"NetConnection.cs"类来解决这个问题并添加此方法:

public Task<byte[]> SendAndReceiveData(byte[] data, int timeout = 10000)
{
    CheckServerUsedAsClient();
    client.GetStream().Write(data, 0, data.Length);

    Task<byte[]> tskReceive = ReceiveFromAsync(this, timeout, true);
    tskReceive.Wait();

    return tskReceive;
}

并使用此方法从"远程服务器"发送请求和接收数据,如下所示:

byte[] requestData = createByteArrayCommand();
Task<byte[]> testTask = netConnectionObj.SendAndReceiveData(requestData);
testTask.Wait();

// testTask.Result <= contains server response