Galosoft.IaaS.RocketMQ 24.12.4.3-nj

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;
        }
    }