一个分布式任务分发框架核心包,一个内存型的MQ。将ws-task-core引入到自己的application,你可以将自己的普通application转变成一个分布式任务分发application。ws-task-core主要提供了Leader节点自动选举,动态增删节点,task数据分发。提供了两种类型的任务,拉数据模式,推数据模式。数据分发支持轮询,随机,HASH。可配置leader是否参与任务处理,可配置节点是否参与leader选举(见下面示例)。

主要功能

提供了两种类型的任务,拉数据模式,推数据模式;数据分发支持集群模式和广播模式;集群:每一条消息只分配到一个节点;广播:每一条消息分配到所有节点;数据分发集群模式支持轮询,随机,HASH;支持配置Leader是否参与任务处理;支持配置Worker节点的数量;支持spring-boot-starter方式,使用@EnableWsTask开启功能;支持节点可视化,打开/task-ui.html即可查看任务分配节点状态;

示例

Maven: 在pom.xml中引入jar

<dependency><groupId>org.ws.task

作者 nasiapp

在线客服
官方客服
我们将24小时内回复。
12:01
您好,有任何疑问请与我们联系!

选择聊天工具: