Mini-MQ

<dependency>
    <groupId>com.uhu</groupId>
    <artifactId>minimq</artifactId>
    <version>1.0</version>
</dependency>

// 注册一个主题和消息处理
SubjectRegistry.register("吃饭", (message) -> System.out.println(LocalDateTime.now() + "|收到消息：吃" + message.getContent()));

/**
 * 字符消息
 */
static class MyMessage extends SimpleMessage<String> {
    /**
     * 全参构造方法
     * @param subject 主题
     * @param content 消息内容
     */
    public MyMessage(String subject, String content) {
        super(subject, content);
    }
}

static class MyDelayedMessage extends AbstractDelayedMessage<String> {

    /**
         * 延时消息构造方法
         * @param subject 主题
         * @param content 消息内容
         * @param delayedTime 延时时间
         * @param timeUnit 延时时间单位
         */
    public MyDelayedMessage(String subject, String content, Long delayedTime, ChronoUnit timeUnit) {
        super(subject, content, delayedTime, timeUnit);
    }
}

// 发送消息
for (int i = 0; i < 100; i++) {
    MessageSender.send(new MyMessage("吃饭", "拉面"));
}
// 发送延时消息
for (int i = 0; i < 10; i++) {
    MessageSender.send(new MyDelayedMessage("吃饭", LocalDateTime.now() + "时做的的拉面", i + 1L, ChronoUnit.SECONDS));
}