特性

快速入门

测试

注册中心

<dependency>    <groupId>com.github.houbb</groupId>    <artifactId>mq-broker</artifactId>    <version>0.1.3</version></dependency>

MqBrokerbroker =newMqBroker();broker.start();

消费者

<dependency>    <groupId>com.github.houbb</groupId>    <artifactId>mq-consumer</artifactId>    <version>0.1.3</version></dependency>

finalMqConsumerPushmqConsumerPush =newMqConsumerPush();mqConsumerPush.start();mqConsumerPush.subscribe("TOPIC","TAGA");mqConsumerPush.registerListener(newIMqConsumerListener() {@OverridepublicConsumerStatusconsumer(MqMessagemqMessage,IMqConsumerListenerContextcontext) {System.out.println("---------- 自定义 " +JSON.toJSONString(mqMessage));returnConsumerStatus.SUCCESS;    }});

生产者

<dependency>    <groupId>com.github.houbb</groupId>    <artifactId>mq-producer</artifactId>    <version>0.1.3</version></dependency>

MqProducermqProducer =newMqProducer();mqProducer.start();Stringmessage ="HELLO MQ!";MqMessagemqMessage =newMqMessage();mqMessage.setTopic("TOPIC");mqMessage.setTags(Arrays.asList("TAGA","TAGB"));mqMessage.setPayload(message);SendResultsendResult =mqProducer.send(mqMessage);System.out.println(JSON.toJSON(sendResult));

前言

技术准备

快速迭代

文档

文档

代码注释

测试

mq 模块

测试代码

后期 ROAD-MAP

中间件等工具开源矩阵