PIG 整合 RocketMQ 集成指南

git clone https://github.com/pig-mesh/rocketmq-docker-compose

vim ./broker.conf

docker-compose up -d

<dependency>
    <groupId>com.pig4cloud.plugin</groupId>
    <artifactId>rocketmq-spring-boot3-starter</artifactId>
    <version>2.2.3</version>
</dependency>

rocketmq:
  name-server: 192.168.0.12:9876
  producer:
    group: test-group

@Slf4j
@Service
@RocketMQMessageListener(topic = "test-topic-1", consumerGroup = "test-group")
public class MyConsumer1 implements RocketMQListener<String> {
    public void onMessage(String message) {
        log.info("received message: {}", message);
    }
}

@SpringBootTest
class DemoApplicationTests {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    @Test
    void contextLoads() {
        rocketMQTemplate.convertAndSend("test-topic-1", "Hello, World!");
    }
}