文章目录
- 1.调整MQ的配置
- 1.进入bin目录
- 2.关闭broker和namesrv
- 3.查看进程确认关闭
- 4.编辑配置文件broker.conf,配置brokerIP1
- 5.开放端口10911
- 6.重新启动
- 1.进入bin目录
- 2.启动mqnamesrv和mqbroker
- 1.启动 NameServer 并将输出重定向到 mqnamesrv.log
- 2.**启动 Broker 并将输出重定向到** **mqbroker.log**
- 3.**实时监控 NameServer 的日志文件**
- 4.**实时监控 Broker 的日志文件**
- 5.查看进程
- 2.项目集成MQ
- 1.domain引入mq依赖
- 2.sun-club-application-mq 引入domain依赖,用于消费mq
- 3.sun-club-starter 引入mq层
- 4.application.yml 配置mq
- 5.SubjectController.java
- 1.依赖注入 RocketMQTemplate
- 2.编写controller,作为消息生产者
- 6.TestConsumer.java 测试消费
- 5.测试
- 3.点赞业务优化为MQ处理
- 1.SubjectLikedMessage.java 点赞消息实体
- 2.sun-club-domain 同步点赞数据
- 1.SubjectLikedDomainService.java
- 2.SubjectLikedDomainServiceImpl.java
- 3.add方法逻辑修改
- 4.测试
1.调整MQ的配置
1.进入bin目录
cd /usr/local/soft/rocketmq-all-4.8.0-bin-release/bin
2.关闭broker和namesrv
sh mqshutdown broker && sh mqshutdown namesrv

3.查看进程确认关闭
ps -ef | grep NamesrvStartup && ps -ef | grep BrokerStartup

4.编辑配置文件broker.conf,配置brokerIP1
vim /usr/local/soft/rocketmq-all-4.8.0-bin-release/conf/broker.conf
namesrvAddr=
brokerIP1=
listenPort=10911
autoCreateTopicEnable=true
5.开放端口10911
systemctl start firewalld && firewall-cmd --permanent --add-port=10911/tcp && firewall-cmd --reload && firewall-cmd --query-port=10911/tcp

6.重新启动
1.进入bin目录
cd /usr/local/soft/rocketmq-all-4.8.0-bin-release/bin
2.启动mqnamesrv和mqbroker
1.启动 NameServer 并将输出重定向到 mqnamesrv.log
nohup sh mqnamesrv > mqnamesrv.log 2>&1 &
2.启动 Broker 并将输出重定向到 mqbroker.log
nohup sh mqbroker -c ../conf/broker.conf > mqbroker.log 2>&1 &
3.实时监控 NameServer 的日志文件
tail -f mqnamesrv.log &

4.实时监控 Broker 的日志文件
tail -f mqbroker.log &
5.查看进程
ps -ef | grep NamesrvStartup && ps -ef | grep BrokerStartup

2.项目集成MQ
1.domain引入mq依赖
<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.1.1</version></dependency>

2.sun-club-application-mq 引入domain依赖,用于消费mq
<dependency><groupId>com.sun.club</groupId><artifactId>sun-club-domain</artifactId><version>1.0-SNAPSHOT</version></dependency>

3.sun-club-starter 引入mq层
<dependency><groupId>com.sun.club</groupId><artifactId>sun-club-application-mq</artifactId><version>1.0-SNAPSHOT</version></dependency>

4.application.yml 配置mq
rocketmq:name-server: producer:group: test-group

5.SubjectController.java
1.依赖注入 RocketMQTemplate
@Resourceprivate RocketMQTemplate rocketMQTemplate;
2.编写controller,作为消息生产者
@GetMapping("/pushMessage")public Result<Boolean> pushMessage(@Param("id") int id) {rocketMQTemplate.convertAndSend("first-topic", "hello " + id);return Result.ok();}

6.TestConsumer.java 测试消费
package com.sunxiansheng.subject.application.mq;import com.sun.media.jfxmedia.logging.Logger;
import groovy.util.logging.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@Component
@RocketMQMessageListener(topic = "first-topic", consumerGroup = "test-group")
@Slf4j
public class TestConsumer implements RocketMQListener<String> {private static final org.slf4j.Logger log = LoggerFactory.getLogger(TestConsumer.class);@Overridepublic void onMessage(String s) {log.info("接受到消息了:{}", s);}}

5.测试


3.点赞业务优化为MQ处理
1.SubjectLikedMessage.java 点赞消息实体
package com.sunxiansheng.subject.domain.entity;import lombok.Data;
import lombok.experimental.Accessors;import java.io.Serializable;
@Data
@Accessors(chain = true)
public class SubjectLikedMessage implements Serializable {private Long subjectId;private String likeUserId;private Integer status;}
2.sun-club-domain 同步点赞数据
1.SubjectLikedDomainService.java
void syncLikedByMsg(SubjectLikedBO subjectLikedBO);
2.SubjectLikedDomainServiceImpl.java
@Overridepublic void syncLikedByMsg(SubjectLikedBO subjectLikedBO) {SubjectLiked subjectLiked = new SubjectLiked();subjectLiked.setSubjectId(subjectLikedBO.getSubjectId());subjectLiked.setLikeUserId(subjectLikedBO.getLikeUserId());subjectLiked.setStatus(subjectLikedBO.getStatus());subjectLiked.setIsDeleted(IsDeleteFlagEnum.UN_DELETED.getCode());subjectLikedService.insert(subjectLiked);}
3.add方法逻辑修改

4.测试

