SpringBoot3.0 + RocketMq 构建企业级数据中台（从0到1整合业务数据）

SpringBoot3.0 + RocketMq 构建企业级数据中台

//xia仔k：https://www.51xuebc.com/thread-616-1-1.html

Spring Boot 3.0 + RocketMQ 是一个集成计划，用于简化 Spring Boot 应用与 RocketMQ 音讯中间件的集成。以下是一个简单的代码概述，协助你了解如何完成这一集成：

添加依赖

首先，你需求在 pom.xml 中添加 RocketMQ 和 Spring Boot 的相关依赖。

xml复制代码

org.springframework.boot

spring-boot-starter-rocketmq

配置 RocketMQ

在 application.properties 或 application.yml 中配置 RocketMQ 的相关属性。

properties复制代码

rocketmq.name-server=127.0.0.1:9876

rocketmq.producer.group=my-producer-group

创立音讯消费者

创立一个音讯消费者类，用于发送音讯到 RocketMQ。

java复制代码

import org.springframework.beans.factory.annotation.Value;

import org.springframework.stereotype.Component;

import org.apache.rocketmq.spring.core.RocketMQTemplate;

import org.apache.rocketmq.spring.core.message.RocketMQMessage;

import org.apache.rocketmq.common.message.Message;

@Component

public class MyMessageProducer {

@Value("${rocketmq.producer.group}")

private String producerGroup;

private final RocketMQTemplate rocketMQTemplate;

public MyMessageProducer(RocketMQTemplate rocketMQTemplate) {

this.rocketMQTemplate = rocketMQTemplate;

}

public void sendMessage(String topic, String message) {

RocketMQMessage rocketMQMessage = new RocketMQMessage(new Message(topic, message));

rocketMQTemplate.convertAndSend(rocketMQMessage);

}

}

创立音讯消费者

创立一个音讯消费者类，用于接纳并处置从 RocketMQ 发送的音讯。

java复制代码

import org.springframework.beans.factory.annotation.Value;

import org.springframework.stereotype.Component;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;

import org.apache.rocketmq.spring.core.RocketMQListener;

import org.apache.rocketmq.common.message.MessageExt;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.context.annotation.EnableRocketMQ;

import org.springframework.context.annotation.ImportResource;

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.*;

import java.util.concurrent.*;

import org.apache.rocketmq.*;

import org.apache.rocketmq.client.*;

import org.apache.rocketmq.client.*;

import org.apache.rocketmq.*;

import org.*;

import org.*;