我有一个问题,我用EasyNetQ实现了简单的RPC (请求/响应),它可以工作,但是我想知道我在响应之后留下了不太漂亮的队列。
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);
}
}所以我的问题是,有没有办法移除那个队列?
发布于 2020-07-09 08:31:17
对任何介入的人来说,我能想到的最好的事情就是..。“使用”就像:
using (var publishChannel = Bus.CreateMessageBus())因此,每次我需要发出请求时,我都要连接到rabbitmq,发出请求等待响应,然后处理请求连接,同时,我还有其他静态连接,这些静态连接做的是恒定的后台工作,而这两者不发生冲突。
但是,根据文档,这是一个好模式吗?
但我会在上面做实验。
https://stackoverflow.com/questions/62789392
复制相似问题