📄 整合 RocketMQ 使用

环境组件	版本	备注
RocketMQ	5.3.0
PigX	5.5
JDK	17	分支：jdk17

@Slf4j
@Service
@RocketMQMessageListener(topic = "TestTopic", consumerGroup = "test-group", tag = "*", filterExpressionType = "tag")
public class MyConsumer1 implements RocketMQListener {
    @Override
    public ConsumeResult consume(MessageView messageView) {
        ByteBuffer body = messageView.getBody();
        String message = StandardCharsets.UTF_8.decode(body).toString();
        log.info("received message: {}", message);
        return ConsumeResult.SUCCESS;
    }
}


@SpringBootTest
class DemoApplicationTests {

    @Autowired
    private RocketMQClientTemplate rocketMQTemplate;

    @Test
    void contextLoads() {
        rocketMQTemplate.convertAndSend("TestTopic", "Hello, World!");
    }
}

remoteLogService.saveLog(sysLog, SecurityConstants.FROM_IN);


@Inner
@PostMapping
public R save(@Valid @RequestBody SysLog sysLog) {
    return new R<>(sysLogService.save(sysLog));
}

TenantContextHolder.set(id);

PIGCLOUD

📄 整合 RocketMQ 使用

📄 整合 RocketMQ 使用

内部资料，请刷新扫码登录

# 环境说明

# 安装 RocketMQ

# 代码整合

# 特殊说明