我有两个控制台应用程序。一个消费者和一个生产者。两者都有自己的用户。在单独的虚拟主机中有一个队列。现在我想将生产者的队列权限设置为只写,但是当我删除配置和读权限时抛出异常 RabbitMQ.Client.Exceptions.OperationInterruptedException: The AMQP operation was interrupted: AMQP close-reason, initiated by Peer, code=403, text='ACCESS_REFUSED - access to exchange ... 当我将.*放回权限的configurati
最初,我有一个单独的rabbitmq节点,可以很好地处理请求/响应客户端交互。
我现在正在切换到集群,并尝试运行完全相同的请求/响应操作。它以惊人的速度爆炸。
我已经设置了两个主机作为rabbitmq集群的一部分。我遇到了如此多的麻烦,以至于我又回到了使用masstransit 。
这似乎也有麻烦。我最终在我的请求服务上得到了一个重复出现的异常:
--- End of stack trace from previous location where exception was thrown --
at System.Runtime.CompilerServices.TaskAwaiter
我们目前有2个Azure Windows虚拟机,每个实例上都安装了我们的所有应用程序。然后对它们进行负载均衡。
就目前而言,这对我们来说在财务上运行良好,因为我们有多个.NET核心API,Angular客户端和.NET完整框架应用程序,这些应用程序目前都在相对较低的负载下运行,所以没有必要将它们分别放在单独的实例上(尽管我们可能会在未来这样做)。
我们最近开发了一个服务总线集成,使用.NET核心,rabbitmq和MassTransit来处理电子邮件和报告生成(因为这些需要一段时间来生成和减慢应用程序)。这一切都在本地运行得很好,我已经准备好部署了。
我想使用Azure Service Bus
我使用的是MassTransit和RaabbitMQ,当我试图发送消息时,我会得到以下错误:
rabbitmq://localhost/FilesVersioning => An exception was thrown during Send
at MassTransit.Transports.Endpoint.Send[T](ISendContext`1 context) in d:\BuildAgent-02\work\aa063b4295dfc097\src\MassTransit\Transports\Endpoint.cs:line 116
at MassTransit
我想创建一个订阅服务器,用于侦听现有的exchange以及使用MassTransit和RabbitMq绑定到该exchange的队列。环境详情: dotnet版本: 4.8 MassTransit版本: 7.1.3
请在下面找到我的订户代码:
using System;
using System.Threading.Tasks;
using Contracts;
using MassTransit;
namespace Subscriber
{
internal class Receive
{
public static async Task Main(str
在我的应用程序中配置错误用户时,我遇到了问题。问题是,所消耗的消息被传递到*_error_skipped队列,并且它不会完全消失。
下面是一个非常简单的例子。客户端应用程序接收失败的消息,并从test_error队列中消失,但它仍然存在于test_error_skipped队列中。
服务项目
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
using GreenPipes;
using MassTransit;
using MassTransit.U
我创建了一个MassTransit快速启动程序来与本地主机RabbitMQ进行交互:
namespace ConsoleApp1
{
public static class Program
{
public class YourMessage
{
public string Text { get; set; }
}
public static async Task Main(params string[] args)
{
var bus = Bus.