1

我正在使用来自 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，但只有新的控制台应用程序正在接收它。为什么其他订阅者没有收到消息？

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

4

1 回答 1

1

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

对于 MQ，订阅者将消息从队列中取出以进行处理。处理后，就是这样。

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

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

于 2012-12-13T19:17:11.477 回答