celery-mq-assistantMQ 助手
MQ助手 - 是一个基于pulsar包自研实现的Spring Boot Stater。通过简单注解配置即可进行MQ消息生产与消费。
主要特性
- 基于成熟pulsar包扩展,没有任何框架变动,只为简化开发使用
- 配置简单灵活,无需复杂的配置文件:开发者可以快速注解类或者方法实现消息的生产与消费
- Apache Pulsar 云原生分布式消息流平台,当下最佳解决方案
使用指引
引入依赖
implementation("cool.doudou:mq-assistant:latest")
Pulsar配置
pulsar:
service-url: pulsar://127.0.0.1:6650
subscription-name: sub-celery
subscription-type: Shared
使用方式
消息订阅
- 生产者与topic进行关联绑定
/**
* 生产者主题绑定
*/
@MqProducer(topics = {"celery"})
@Component
public class MqComponent {
}
- 消费者与topic进行关联绑定,注意:每个消费者须绑定一个subscription-name后才能进行消费
/**
* 消费者主题绑定
*/
@Component
public class MqComponent {
@MqConsumer(topics = {"celery"})
public void receive(String topic, byte[] msg) {
System.out.println("consumer: topic[" + topic + "] => " + new String(msg));
}
}
消息发送
- send():发送
- sendAsync():异步发送
/**
* 消息发送
*/
@AllArgsConstructor
@Service
public class MqServiceImpl {
private MqHelper mqHelper;
public void test() {
// 同步
String msgId = mqHelper.send("celery", "hello");
System.out.println("send: " + msgId);
// 异步
mqHelper.sendAsync("celery", "您好Async", System.out::println);
// 同步
String msgId = mqHelper.send("celery", new byte[]{0x01, 0x02, 0x03, 0x04});
System.out.println("send: " + msgId);
// 异步
mqHelper.sendAsync("celery", new byte[]{0x01, 0x02, 0x03, 0x04}, System.out::println);
}
}
评论
a11y.jsJS 助手
a11y.js是一套用于辅助功能属性的JS助手。a11y.state是第一套可用的JS助手,它主要应用于ARIAStates集合。它包括三个功能,安装、切换、删除。a11y.state通过发出警告和提
a11y.jsJS 助手
0
celery-mqtt-assistantMQTT 助手
Mqtt助手-是一个基于spring-integration-mqtt包自研实现的SpringBootStater。通过简单注解配置即可进行MQTT协议通信。在物联网环境中可以非常方便的结合完成与设备
celery-mqtt-assistantMQTT 助手
0
右键助手
作用:用来给程序添加某种相关文件的右键打开,像平时用的记事本打开方式一样如图: (红色为:系统,蓝色为:右键助手1.0添加的)但有些软件或重装了电脑,虽然软件还可以正常使用,但右键打开某文件的方式已经
右键助手
0
StreamyJScala 助手
StreamyJ是JSON解析器上Jackson流的Scala助手。使用一些(可能完全不可靠的)基准来表明Jackson库明显的快于GSON库,这似乎非常受非流式JSON解析器的欢迎。StreamyJ
StreamyJScala 助手
0
Diagnil填字游戏助手
Diagnil是专门设计用于diagramless字谜游戏的解算器。它支持解算智力游戏-印刷体分布、Lite/XPF文件格式分布。它可以运行在Windows,macosx,Linux系统/Unix系统
Diagnil填字游戏助手
0