未使用Redis MQ呼叫的第一个订阅者

Question

我正在使用ServiceStack可重用性用例项目中的解决方案。

对于这个解决方案，我添加了一个新的控制台应用程序，其中包含以下代码。

对于最初的可重用性用例项目，当EmailMessage发布时，它由发送电子邮件(即SMessageService.Any(EmailMessage请求))的订阅者处理。

当我运行控制台应用程序时，这意味着我有两个订阅EmailMessage的应用程序，只有新的控制台应用程序会收到消息。

我有以下几点：

我的控制台应用是：

class Program
{
    static void Main(string[] args)
    {
        var subscriberHost = new SubscriberHost();
        subscriberHost.Init();

        Console.WriteLine("Waiting of publishing 
                to happen on EmailMessage as we are subscribing to it...");
        Console.ReadLine();
    }
}

public class SubscriberHost : AppHostHttpListenerBase
{
    private RedisMqServer mqHost;

    public SubscriberHost() 
      :base("Subscriber console",typeof(EmailMessageEventHandler).Assembly)
    {

    }


    public override void Configure(Container container)
    {
        var redisFactory = new PooledRedisClientManager("localhost:6379");
        mqHost = new RedisMqServer(redisFactory, retryCount:2);

        mqHost.RegisterHandler<EmailMessage>((message) =>
                           {
                                 var emailMessage = message.GetBody();
                                 Console.WriteLine(emailMessage.To);
                                 Console.WriteLine(emailMessage.Subject);
                                 Console.WriteLine(emailMessage.Body);
                                 return new SMessageReceipt {
                                           Type = "not used",
                                           To = "test",
                                           From = "Reusability",
                                           RefId = "1,"
                                   };
                                                                      });
   // mqHost.RegisterHandler<EmailMessage>(ServiceController.ExecuteMessage);
   mqHost.Start();
    }
}

我预计两个订阅者都会收到EmailMessage，但只有新的控制台应用程序会收到它。为什么另一个订阅者没有收到消息？

执行发布的客户端代码尚未修改。

Answer 1

我在上面展示的是使用Redis MQ，对于我测试的多订阅者问题，我需要Redis Pub/Sub。

对于MQ，订阅者将消息从队列中取出进行处理。一旦处理完毕，就是这样了。

对于发布/订阅，可能有许多订阅者，每个订阅者都将收到一份消息副本。

我希望这对其他人有帮助。