在 c# 中使用同步外观进行异步调用的代理

Question

我想通过 websocket 进行多次调用，并为每次调用获取结果。

即

_svc.DoAthing(param) =broker calls=> ws.SendMessage(doathingmessage(ticket))
                     <=broker returns= ws.Onmessage+=handler=>(doathingresult(ticket))

使经纪人成为

的最佳方式是什么

这个异步请求看起来是同步的
代理可以处理数百个请求
客户端不应该不断地轮询它的线程，它应该阻塞或等待。

不确定让一堆线程轮询完成的票证是否是最好的方法。

Answer 1

我认为这会很好用，但我仍在寻找更优雅的解决方案

    private ConcurrentDictionary<Guid, ManualResetEvent> _waitingClients = new ConcurrentDictionary<Guid, ManualResetEvent>();
    private ConcurrentDictionary<Guid, byte[]> _hostResponses = new ConcurrentDictionary<Guid, byte[]>();

    public TEventResult SendCommand<TEventResult>(ICommand cmd)
    {
        var mre = new ManualResetEvent(false);
        var s = _serialize(cmd);
        if(_waitingClients.TryAdd(cmd.Ticket, mre))
        {
            if (!_sendDownPipe(s))
            {
                _waitingClients.TryRemove(cmd.Ticket, out mre);
                throw new Exception("Could not get Response");
            }
        }
        mre.WaitOne();//todo timeout

        byte[] resp;
        if(_hostResponses.TryRemove(cmd.Ticket, out resp))
        {
            var o = _deserialize<TEventResult>(resp);
            return o;
        }

        throw new Exception("Could not get response!");
    }
    private void _eventRecieved(byte[] s)
    {
        var evt = _deserialize<IEvent>(s);
        if(_hostResponses.TryAdd(evt.Ticket, s))
        {
            ManualResetEvent mre;
            if(_waitingClients.TryRemove(evt.Ticket, out mre))
            {
                mre.Set();
            }
        }
    }

在 c# 中使用同步外观进行异步调用的代理

Broker that makes async calls with a synchronous facade in c#

c#

multithreading

threadpool

messagebroker

websocket-sharp