清理 EasyNetQ RPC 队列

Question

我有一个问题，我已经使用 EasyNetQ 实现了简单的 RPC (Request/Response)，它可以工作，但我想知道在我回应之后我留下了不那么漂亮的队列，例如

easynetq.response.b01688d1-35c8-4b66-b127-57cd6a155961

这个 RPC 可能每个月在几个服务上使用一次，所以将它留在那里会导致队列列表不可读。

我的请求方法如下：

    public async Task Request<TRequest, TResponse>(TRequest request, Action<Task<TResponse>> onResponse)
        where TRequest : class
        where TResponse : class
    {
        try
        {
            Console.WriteLine("Publishing Request: {0}", request);
            await this.bus.RequestAsync<TRequest, TResponse>(request).ContinueWith(onResponse);
        }
        catch (TaskCanceledException ex)
        {
            Console.WriteLine("Task Failed: {0}", ex);
        }
        catch (EasyNetQException ex)
        {
            Console.WriteLine("Publish Request Failed: {0}", ex);
        }
    }

我的回复：

    public void Response<TRequest, TResponse>(Func<TRequest, Task<TResponse>> onResponse)
        where TRequest : class
        where TResponse : class
    {
        try
        {
            bus.RespondAsync(onResponse);
        }
        catch (EasyNetQException ex)
        {
            Console.WriteLine("Respond Failed: {0}", ex);
        }
    }

所以我的问题是，有没有办法删除该队列？

Answer 1

对于任何感兴趣的人，我能想到的最好的办法就是使用 .. 以及“使用”，例如：

using (var publishChannel = Bus.CreateMessageBus())

所以每次我需要发出请求时，我都会连接到 rabbitmq 发出等待响应的请求，然后处理请求连接，同时我还有其他静态连接在做持续的后台工作，这两者不会冲突。

但是根据文档，这是一个好的模式吗？

不过我会试验一下。

清理 EasyNetQ RPC 队列

Clean EasyNetQ RPC queue

c#

easynetq