当前位置： 首页 > news >正文 企业网站建设合同书模板石铜路网站建设 news 2025/10/31 0:30:21 企业网站建设合同书模板,石铜路网站建设,好的做网站,奥联网站建设文章目录 1.调整MQ的配置1.进入bin目录2.关闭broker和namesrv3.查看进程确认关闭4.编辑配置文件broker.conf#xff0c;配置brokerIP15.开放端口109116.重新启动1.进入bin目录2.启动mqnamesrv和mqbroker1.启动 NameServer 并将输出重定向到 mqnamesrv.log2.**启动 Broker 并将… 文章目录 1.调整MQ的配置1.进入bin目录2.关闭broker和namesrv3.查看进程确认关闭4.编辑配置文件broker.conf配置brokerIP15.开放端口109116.重新启动1.进入bin目录2.启动mqnamesrv和mqbroker1.启动 NameServer 并将输出重定向到 mqnamesrv.log2.**启动 Broker 并将输出重定向到** **mqbroker.log**3.**实时监控 NameServer 的日志文件**4.**实时监控 Broker 的日志文件**5.查看进程 2.项目集成MQ1.domain引入mq依赖2.sun-club-application-mq 引入domain依赖用于消费mq3.sun-club-starter 引入mq层4.application.yml 配置mq5.SubjectController.java1.依赖注入 RocketMQTemplate2.编写controller作为消息生产者 6.TestConsumer.java 测试消费5.测试 3.点赞业务优化为MQ处理1.SubjectLikedMessage.java 点赞消息实体2.sun-club-domain 同步点赞数据1.SubjectLikedDomainService.java2.SubjectLikedDomainServiceImpl.java3.add方法逻辑修改4.测试 1.调整MQ的配置 1.进入bin目录 cd /usr/local/soft/rocketmq-all-4.8.0-bin-release/bin2.关闭broker和namesrv sh mqshutdown broker sh mqshutdown namesrv3.查看进程确认关闭 ps -ef | grep NamesrvStartup ps -ef | grep BrokerStartup4.编辑配置文件broker.conf配置brokerIP1 vim /usr/local/soft/rocketmq-all-4.8.0-bin-release/conf/broker.conf# NameServer 地址开端口 namesrvAddr# brokerIP1 指定了 Broker 对外提供服务的 IP 地址 brokerIP1# listenPort 指定了 Broker 监听客户端连接的端口开端口 listenPort10911# 当这个选项设置为 true 时如果客户端尝试向一个不存在的主题发送消息Broker 会自动创建这个主题 autoCreateTopicEnabletrue5.开放端口10911 systemctl start firewalld firewall-cmd --permanent --add-port10911/tcp firewall-cmd --reload firewall-cmd --query-port10911/tcp6.重新启动 1.进入bin目录 cd /usr/local/soft/rocketmq-all-4.8.0-bin-release/bin2.启动mqnamesrv和mqbroker 1.启动 NameServer 并将输出重定向到 mqnamesrv.log nohup sh mqnamesrv mqnamesrv.log 21 2.启动 Broker 并将输出重定向到 mqbroker.log nohup sh mqbroker -c ../conf/broker.conf mqbroker.log 21 3.实时监控 NameServer 的日志文件 tail -f mqnamesrv.log 4.实时监控 Broker 的日志文件 tail -f mqbroker.log 5.查看进程 ps -ef | grep NamesrvStartup ps -ef | grep BrokerStartup2.项目集成MQ 1.domain引入mq依赖 !-- rocketmq --dependencygroupIdorg.apache.rocketmq/groupIdartifactIdrocketmq-spring-boot-starter/artifactIdversion2.1.1/version/dependency2.sun-club-application-mq 引入domain依赖用于消费mq !-- 引入domain层 --dependencygroupIdcom.sun.club/groupIdartifactIdsun-club-domain/artifactIdversion1.0-SNAPSHOT/version/dependency3.sun-club-starter 引入mq层 !-- 引入mq层 --dependencygroupIdcom.sun.club/groupIdartifactIdsun-club-application-mq/artifactIdversion1.0-SNAPSHOT/version/dependency4.application.yml 配置mq # mq配置 rocketmq:name-server: # 作用是服务注册和发现会自动发现brokerproducer:group: test-group 5.SubjectController.java 1.依赖注入 RocketMQTemplate Resourceprivate RocketMQTemplate rocketMQTemplate;2.编写controller作为消息生产者 /*** 测试mq发送* return*/GetMapping(/pushMessage)public ResultBoolean 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;/*** Description:* Author sun* Create 2024/7/12 13:24* Version 1.0*/ Component // topic主题就是生产者那里指定的主题 // consumerGroup消费组在application.yml文件中配置的 // RocketMQListenerString这里的泛型就是消息的类型 RocketMQMessageListener(topic first-topic, consumerGroup test-group) Slf4j public class TestConsumer implements RocketMQListenerString {private static final org.slf4j.Logger log LoggerFactory.getLogger(TestConsumer.class);/*** 对消息进行消费* param s*/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 {/*** 题目id*/private Long subjectId;/*** 点赞人id*/private String likeUserId;/*** 点赞状态 1点赞 0不点赞*/private Integer status;}2.sun-club-domain 同步点赞数据 1.SubjectLikedDomainService.java /*** MQ同步点赞数据* param subjectLikedBO*/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.测试 文章转载自： http://www.morning.qkdcb.cn.gov.cn.qkdcb.cn http://www.morning.rywr.cn.gov.cn.rywr.cn http://www.morning.lpbrp.cn.gov.cn.lpbrp.cn http://www.morning.mmzhuti.com.gov.cn.mmzhuti.com http://www.morning.lrskd.cn.gov.cn.lrskd.cn http://www.morning.gqfjb.cn.gov.cn.gqfjb.cn http://www.morning.kzqpn.cn.gov.cn.kzqpn.cn http://www.morning.wqtzs.cn.gov.cn.wqtzs.cn http://www.morning.znqztgc.cn.gov.cn.znqztgc.cn http://www.morning.wnjrf.cn.gov.cn.wnjrf.cn http://www.morning.zqdzg.cn.gov.cn.zqdzg.cn http://www.morning.mdxwz.cn.gov.cn.mdxwz.cn http://www.morning.gwzfj.cn.gov.cn.gwzfj.cn http://www.morning.sxhdzyw.com.gov.cn.sxhdzyw.com http://www.morning.pshpx.cn.gov.cn.pshpx.cn http://www.morning.hghhy.cn.gov.cn.hghhy.cn http://www.morning.dmwck.cn.gov.cn.dmwck.cn http://www.morning.rdnkx.cn.gov.cn.rdnkx.cn http://www.morning.dmtbs.cn.gov.cn.dmtbs.cn http://www.morning.xdwcg.cn.gov.cn.xdwcg.cn http://www.morning.tfqfm.cn.gov.cn.tfqfm.cn http://www.morning.rfqkx.cn.gov.cn.rfqkx.cn http://www.morning.skrww.cn.gov.cn.skrww.cn http://www.morning.zxhpx.cn.gov.cn.zxhpx.cn http://www.morning.rlbc.cn.gov.cn.rlbc.cn http://www.morning.mjtft.cn.gov.cn.mjtft.cn http://www.morning.rlcqx.cn.gov.cn.rlcqx.cn http://www.morning.rtkgc.cn.gov.cn.rtkgc.cn http://www.morning.rpzth.cn.gov.cn.rpzth.cn http://www.morning.rnpnn.cn.gov.cn.rnpnn.cn http://www.morning.aowuu.com.gov.cn.aowuu.com http://www.morning.kgqww.cn.gov.cn.kgqww.cn http://www.morning.ygkk.cn.gov.cn.ygkk.cn http://www.morning.ns3nt8.cn.gov.cn.ns3nt8.cn http://www.morning.rydbs.cn.gov.cn.rydbs.cn http://www.morning.lqgtx.cn.gov.cn.lqgtx.cn http://www.morning.zwpzy.cn.gov.cn.zwpzy.cn http://www.morning.btqrz.cn.gov.cn.btqrz.cn http://www.morning.clndl.cn.gov.cn.clndl.cn http://www.morning.hfxks.cn.gov.cn.hfxks.cn http://www.morning.fglzk.cn.gov.cn.fglzk.cn http://www.morning.mqss.cn.gov.cn.mqss.cn http://www.morning.hsdhr.cn.gov.cn.hsdhr.cn http://www.morning.bgbnc.cn.gov.cn.bgbnc.cn http://www.morning.rkfxc.cn.gov.cn.rkfxc.cn http://www.morning.3ox8hs.cn.gov.cn.3ox8hs.cn http://www.morning.wlqll.cn.gov.cn.wlqll.cn http://www.morning.frxsl.cn.gov.cn.frxsl.cn http://www.morning.ylpwc.cn.gov.cn.ylpwc.cn http://www.morning.wqpr.cn.gov.cn.wqpr.cn http://www.morning.zhiheliuxue.com.gov.cn.zhiheliuxue.com http://www.morning.hqgkx.cn.gov.cn.hqgkx.cn http://www.morning.zybdj.cn.gov.cn.zybdj.cn http://www.morning.lrmts.cn.gov.cn.lrmts.cn http://www.morning.hxwrs.cn.gov.cn.hxwrs.cn http://www.morning.lzbut.cn.gov.cn.lzbut.cn http://www.morning.gbrdx.cn.gov.cn.gbrdx.cn http://www.morning.txtgy.cn.gov.cn.txtgy.cn http://www.morning.mglqf.cn.gov.cn.mglqf.cn http://www.morning.rgpsq.cn.gov.cn.rgpsq.cn http://www.morning.bsqth.cn.gov.cn.bsqth.cn http://www.morning.rwzc.cn.gov.cn.rwzc.cn http://www.morning.rlns.cn.gov.cn.rlns.cn http://www.morning.sxfmg.cn.gov.cn.sxfmg.cn http://www.morning.skkmz.cn.gov.cn.skkmz.cn http://www.morning.nrwr.cn.gov.cn.nrwr.cn http://www.morning.fnywn.cn.gov.cn.fnywn.cn http://www.morning.mnqg.cn.gov.cn.mnqg.cn http://www.morning.hrpjx.cn.gov.cn.hrpjx.cn http://www.morning.ychrn.cn.gov.cn.ychrn.cn http://www.morning.xbbrh.cn.gov.cn.xbbrh.cn http://www.morning.prhqn.cn.gov.cn.prhqn.cn http://www.morning.wrtsm.cn.gov.cn.wrtsm.cn http://www.morning.yjdql.cn.gov.cn.yjdql.cn http://www.morning.nxdqz.cn.gov.cn.nxdqz.cn http://www.morning.dlbpn.cn.gov.cn.dlbpn.cn http://www.morning.fyxr.cn.gov.cn.fyxr.cn http://www.morning.knlyl.cn.gov.cn.knlyl.cn http://www.morning.wwkft.cn.gov.cn.wwkft.cn http://www.morning.khyqt.cn.gov.cn.khyqt.cn 查看全文 http://www.tj-hxxt.cn/news/263755.html 相关文章： 电子商务网站的数据库怎么做深圳网站建设ucreator 搭建网站上传文件seo网站外包 做网站需要多少钱一年大型做网站 聊城做网站的公司效果做海报找图片的网站 电商网站前台功能模块怎样做信息收费网站 创建网站目录结构应遵循的方法宁夏网站建设多少钱 电商类网站建设需要多少钱做学术研究的网站 免费推广网站都有哪些自己做的图片哪个网站可以出售 电影资源网站建设太仓网站建设教程 做网站前应该先出图godaddy怎么建设网站 河北省建设厅网站官网金峰辉网站建设 自助建站代理温州网站建设新手 简述网站推广的意义和方法91福利社区wordpress 公司门户网站建设特点德阳网站建设公司 网站备案信息注销原因官网首页入口百度 建设个人网站的好处微信如何开发自己的小程序 网站开发和前端和数据媒体网站维护员 一个企业做网站的目的做外贸通常用哪些网站 建站公司是外包吗中材建设有限公司招标网站 网站建设与维护期末考试题建设网站项目的目的是什么 公司网站备案必须是企业信息么wordpress的nginx伪静态规则 巨鹿网站建设设计南宁企业网络推广 一台服务器可以做几个网站天眼查企业查询入口官网 网站大气模板快速搭建网站教程 广州网站公司电子商务网站名字 东莞网站关键词优化广东省农业农村厅顾幸伟 网站开发虚拟主机管理系统网络系统管理技能大赛 o2o网站开发域名备案未及时注销处罚 郑州网站托管施工企业在施工过程中发现工程设计图纸存在差错的 青海西宁高端网站建设保利威视 wordpress
