Masstransit में क्वार्ट्ज के साथ बहा

यह लेख आपको बताएगा कि बस में संदेश भेजने के लिए एक शेडयूलर को कॉन्फ़िगर करने के लिए मैसट्रांसिट और क्वार्ट्ज का उपयोग कैसे करें। एक बस संदेश भेजने वालों और बस के माध्यम से उनकी सदस्यता लेने वालों के बीच एक कमजोर संबंध का एक अभिन्न अंग है। संदेशों के प्रेषक और रिसीवर केवल संदेश का प्रकार (यह इंटरफ़ेस है) जानते हैं, लेकिन वे एक दूसरे के बारे में कुछ भी नहीं जानते हैं।

Masstransit में क्वार्ट्ज नियंत्रण एक कतार के माध्यम से होता है, हम इसके लिए एक कतार आवंटित करते हैं:

Startup.cs

cfg.UseInMemoryScheduler(sheduleConfig.QuartzQueue); 

सभी कोड देखें

शेडयूलर तक पहुंच के बिंदु पर (मेरे उदाहरण में, यह नियंत्रक विधि है), हमें दिए गए कतार के लिए ISendEndpoint ऑब्जेक्ट मिलता है:

 ISendEndpoint _sendEndpoint = await _sendEndpointProvider.GetSendEndpoint(new Uri($"rabbitmq://{configs.Host}/{configs.QuartzQueue}")); 

और हम एक निश्चित कतार में आवधिक संदेश शेडिंग के लिए सेटिंग्स के साथ एक संदेश भेजते हैं:

 _sheduler.ScheduledRecurringMessage = await _sendEndpoint.ScheduleRecurringSend<IRepeatingCommand>( new Uri($"rabbitmq://{configs.Host}/{configs.DestinationQueue}"), new PollExternalSystemSchedule(), new { Message = $"1 sec Quartz {User.Identity.Name}" }); 

PollExternalSystemSchedule आवृत्ति सेटिंग्स

  public class PollExternalSystemSchedule : DefaultRecurringSchedule { public PollExternalSystemSchedule() { StartTime = DateTime.UtcNow; CronExpression = "* * * * * ? *";//1 sec } } 

आवृत्ति सेट करने के लिए लाइन यहां उत्पन्न की जा सकती है ।

आप पहले से ही उपभोक्ताओं को उस बस से बांध सकते हैं जिस पर शेड्यूलर संदेश भेजेंगे (जो संदेश प्राप्त करते हैं):

 cfg.ReceiveEndpoint(host, sheduleConfig.DestinationQueue, e => { e.ConfigureConsumer<ShedulerCommandConsumer>(provider); }); 

उपभोक्ता पते (ऊपर कतार पता) और इंटरफ़ेस से बंधा हुआ है:

  public class ShedulerCommandConsumer : IConsumer<IRepeatingCommand> { private ILogger<ShedulerCommandConsumer> _logger; public ShedulerCommandConsumer(ILogger<ShedulerCommandConsumer> loger) { _logger = loger; } public Task Consume(ConsumeContext<IRepeatingCommand> context) { _logger.LogInformation($"Call consumer: {typeof(ShedulerCommandConsumer)} {context.Message.Message} {DateTime.UtcNow} "); return Task.CompletedTask; } } 

शेड्यूलर को रोकने के लिए, कॉल करें:

 await _sendEndpoint.CancelScheduledRecurringSend(_sheduler.ScheduledRecurringMessage); 

स्रोत कोड

मैं आपको सागा राज्य मशीन के काम के बारे में भी बता सकता हूं (एक वास्तविक परियोजना में, संदेश इसके माध्यम से भी जा सकते हैं)।