aspnetcore继承kafka封装好可以直接丢项目

时间：2021-09-03 19:12:08 收藏：0 阅读：64

前段时间在项目中把用到kafka组件完全剥离开出来，项目需要可以直接集成进去。源代码如下：

exercise/netcore.demo/NC.EntityFramework at master · liuzhixin405/exercise (github.com)

组件结构如下，代码太多不一一列举，可以去git上看：

技术分享图片

使用规则如下：

技术分享图片

1、新建消费事件和生产服务

2、program中引入即可

                .UseMessageBus(
                (serviceProvider) => new List<IProducer>() { new Producer<SendOrderEvent>() }
                ,
                (serviceProvider) => new List<IConsumer>() { new Consumer<SendOrderEvent, MessageBusTestHandler>($"{ConstDefine.Messagebus_SendOrderTopic}", "SendOrderPersistence") }

                )

原文：https://www.cnblogs.com/morec/p/15222587.html