首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >清除EasyNetQ RPC队列

清除EasyNetQ RPC队列
EN

Stack Overflow用户
提问于 2020-07-08 07:11:49
回答 1查看 948关注 0票数 0

我有一个问题,我用EasyNetQ实现了简单的RPC (请求/响应),它可以工作,但是我想知道我在响应之后留下了不太漂亮的队列。

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

这个RPC可能每个月在几个服务上使用一次,因此将其留在那里将导致队列列表不可读。

我的请求方法看起来如下:

代码语言:javascript
复制
    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);
        }
    }

我的回应是:

代码语言:javascript
复制
    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);
        }
    }

所以我的问题是,有没有办法移除那个队列?

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2020-07-09 08:31:17

对任何介入的人来说,我能想到的最好的事情就是..。“使用”就像:

代码语言:javascript
复制
using (var publishChannel = Bus.CreateMessageBus())

因此,每次我需要发出请求时,我都要连接到rabbitmq,发出请求等待响应,然后处理请求连接,同时,我还有其他静态连接,这些静态连接做的是恒定的后台工作,而这两者不发生冲突。

但是,根据文档,这是一个好模式吗?

但我会在上面做实验。

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/62789392

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档