redis - ServiceStack MessageFactory发布

Question

我一直在此处查看 ServiceStack Messaging with Redis 文档:

https://github.com/ServiceStack/ServiceStack/wiki/Messaging-and-redis

似乎很好地解释了基础知识。我不太明白的是通过 MessageFactory 发布时的差异和适用的用例:

.CreateMessageProducer.Publish()

和

.CreateMessageQueueClient.Publish()

我计划审查代码，但想将其发布在这里以获得“官方”解释。

Answer 1

这是 IMessageProducer 的 API和 IMessageQueueClient :

public interface IMessageProducer : IDisposable
{
    void Publish<T>(T messageBody);
    void Publish<T>(IMessage<T> message);
}

public interface IMessageQueueClient : IMessageProducer
{
    void Publish(string queueName, byte[] messageBytes);
    void Notify(string queueName, byte[] messageBytes);
    byte[] Get(string queueName, TimeSpan? timeOut);
    byte[] GetAsync(string queueName);
    string WaitForNotifyOnAny(params string[] channelNames);
}

基本上是一个MessageQueueClient 是也是MessageProducer ，但除了发布以获取队列中的消息以及发布和订阅任何 MQ 主题之外，还包含其他细粒度方法。

输入的 Publish<T>消息客户端和生产者上的 API 具有相同的行为。