Galosoft.IaaS.RocketMQ 25.9.29.8-rc3

DI

 services.AddRocketMQ(ctx.Configuration);//新增：rmqclient galo@2023-9-28 10:18:41

发送及函数接受消息

 using (var scope = _scopeFactory.CreateScope())
 {
 var sp = scope.ServiceProvider;
 var rmq = sp.GetRequiredService<RmqTemplate>();

 var topic = "oc_test";
 var tag = "order_created";
 await rmq.SendAsync(new SpringBootMqTestRequest(1), topic, tag);
 //await _rmq.HandleAsync<SpringBootMqTestRequest>(async msg =>
 //{
 // await Task.Delay(100);
 // return true;
 //}, topic, "*");
 //await _rmq.HandleAsync<SpringBootMqTestRequest>(async msg =>
 //{
 // await Task.Delay(100);
 // return true;
 //}, topic, tag);
 }

类定义接受消息

 [Handler]
 internal class SpringBoottRmqTestHandler : IMessageHandler<SpringBootMqTestRequest>
 {
 /// <summary>
 /// ConsumerGroup不设置时 配置文件的值或者默认值<see cref="Env.GetApplicationContext"/>,设置ConsumerGroup 为发布订阅模式，同一个ConsumerGroup为工作者模式 galoS@2024-12-5 14:41:20
 /// </summary>
 /// <param name="msg"></param>
 /// <returns></returns>
 [RmqHandler("cs_first")]
 public async Task<bool> HandleAsync(SpringBootMqTestRequest msg)
 {
 Tracer.Trace(msg.Id, "1");
 await Task.Delay(10);
 return true;
 }
 }