linzhiqiang 

kafka实现的messagebus组件 支持手工提交offset模式（根据批量和时间） 支持根据分组订阅 支持根据key路由到固定分区

Foundatio的MessageBus的kafka实现 兼容standard2.0 支持手工提交offset模式（根据批量和时间） 支持根据分组订阅 通过Aix.KafkaMessageBus组件实现

分布式定时任务:数据库实现支持 sqlserver、mysql

封装dapper的ORM框架

MessageBus的kafka实现 支持手工提交offset模式（根据批量和时间） 支持根据分组订阅

MessageBus通用接口定义

redis版即时任务(stream)和延迟任务(zset)

本地多线程执行器,支持本地延迟任务

NATs client unified interface encapsulation,Implement publish subscribe mode, queue mode and request response mode. You can also use jetstream.

redis实现messagebus功能 即时任务 延时任务

开源分布式任务框架xxl-job的netcore版本的执行器实现

定时送任务封装

MessageBus的redis实现

MessageBus的rabbitMQ实现

redis实现延迟任务队列

rabbitmq实现messagebus 通过延迟队列插件实现延迟队列及任务重试

UidGenerator 默认设置 1(符号位)+41(毫秒时间戳)+10(机器位)+2(时间回拨位)+10(同一毫秒内递增序号) 可进行灵活调整

Package Description

Package Description

Package Description