ServiceStack.Redis की समझ लेना

Aug 17 2020

मैं एक मुश्किल समय अलग हो रहा है IRedisClient.PublishMessageऔर IMessageQueueClient.Publishऔर महसूस मैं कुछ मिश्रण होना चाहिए।

ServiceStack हमें इस तरह पब / उप प्रसारण के लिए सुनने का विकल्प देता है:

    static IRedisSubscription _subscription;
    static IRedisClient redisClientSub;
    static int received = 0;
    static void ReadFromQueue()
    {
        redisClientSub = redisClientManager.GetClient();
        _subscription = redisClientSub.CreateSubscription();

        _subscription.OnMessage = (channel, msg) =>
        {
            try
            {
                received++;
            }
            catch (Exception ex)
            {
                    
            }
        };

        Task.Run(() => _subscription.SubscribeToChannels("Test"));
    }

अच्छा, सीधा सा लगता है। लेकिन निर्माता के बारे में क्या?

जब कक्षाएं उपलब्ध को देखते हुए, मैंने सोचा था कि एक या तो कर सकते थे उपयोगकर्ता IRedisClient.PublishMessage(string toChannel, string message)या IMessageQueueClient.Publish(string queueName, IMessage message)।

redisClient.PublishMessage("Test", json);
// or:     
myMessageQueueClient.Publish("Test", new Message<CoreEvent>(testReq));

दोनों स्थितियों में, आप चैनल का नाम स्वयं निर्दिष्ट करते हैं। यह वह व्यवहार है जिसे मैं देख रहा हूं:

यदि मैं उपयोग करता हूं तो उपर्युक्त सदस्य केवल संदेश प्राप्त करता है IRedisClient.PublishMessage(string toChannel, string message)और यदि मैं उपयोग करता हूं तो कभी नहींIMessageQueueClient.Publish(string queueName, IMessage message)
यदि मैं उपयोग करके प्रकाशित करता हूं IRedisClient.PublishMessage, तो मुझे उम्मीद है कि "टेस्ट" चैनल आबाद होगा (यदि मैं एक रेडिस ब्राउज़र के साथ देखता हूं), लेकिन यह नहीं है। मुझे कभी भी कतार का कोई निशान नहीं दिखता (मान लें कि मैं सदस्यता शुरू नहीं करता, लेकिन निर्माता संदेश जोड़ते हैं)
यदि मैं उपयोग करके प्रकाशित करता हूं IMessageQueueClient.Publish(string queueName, IMessage message), तो चैनल "टेस्ट" बनाया जाता है और संदेश वहां बने रहते हैं, लेकिन कभी भी पॉप-अप / प्रसारित और हटाए नहीं गए।

मैं दोनों के बीच के अंतर को समझना चाहता हूं। मैंने स्रोत कोड को देखा है और इसके बारे में सभी पढ़ सकते हैं, लेकिन मुझे इसके बारे में कोई दस्तावेज नहीं मिला है IRedisClient.PublishMessage।

ServiceStack.Redis की समझ लेना

जवाब