专业

深圳网站优化客服热线:SEO

揭秘百度SEO快排7天上首页秘籍详情

深圳网站优化

当前位置:首页 > 技术教程

史上最便捷搭建RocketMQ服务器的方法 - osc_pl358sty的个人空间 - OSCHINA

来源: 作者: 访问次数:138

史上最便捷搭建RocketMQ服务器的方法

o
 osc_pl358sty 发布于 15分钟前
字数 1707
阅读 28
收藏 0
点赞 0
评论 0
dockerapachermqspring bootjavagithubrocketmq-springapache rocketmq

【推荐阅读】微服务还能火多久?>>>

最近学习使用 rocketmq,需要搭建 rocketmq 服务端,本文主要记录 rocketmq 搭建过程以及这个过程踩到的一些坑。至于有多简单呢,在本机已有Docker环境的情况下只需要三步即可。

  1. 从github上面拉取项目

  2. 修改broker.conf中的brokerIP1 参数,修改为本机IP

  3. 进入docker-compose.yml文件所在路径,执行docker-compose up命令即可

前言

首先我们是使用Docker进行搭建环境的,所以我们先要在自己机器上的安装Docker,具体的安装过程以及对于Docker的介绍官方文档里面说的很清楚了https://docs.docker.com/get-started/。

我们要搭建RocketMQ服务器,那么我们就要知道大概搭建RocketMQ服务器需要部署哪些东西。对于RocketMQ有一个架构图,如下所示。而图中所示的Producer(生产者)和Consumer(消费者)无需我们搭建,因为那是作为一个服务器进行启动的。nameserver就是一个注册中心一样组件,我们可以将其简单理解成springcloud中的Eureka,那么nameserver是需要我们搭建的。broker就是真正处理消息的地方,也是需要我们搭建的。

RocketMQ架构图

正常情况我们搭建上面所提到的两个组件其实就能已经能够满足我们的发送接收消息的需求了。但是通常情况下我们还需要搭建一个Web可视化的平台用来查看MQ的服务状态、消息的消费情况、主题的队列配置等等。这里使用rocketmq-console。同样也是通过Docker来进行安装。

部署

上面我们提到了需要安装三个组件,那么这三个组件又是需要能够互相通信连接的,考虑到分开部署进行配置连接信息比较麻烦,于是这里我们采用docker-compose进行配置部署。

首先我们需要创建docker-compose.yml配置文件。文件内容如下

version: '3.5'services:  rmqnamesrv:    image: foxiswho/rocketmq:server    container_name: rmqnamesrv    ports:
      - 9876:9876
    volumes:
      - ./logs:/opt/logs
      - ./store:/opt/store    networks:        rmq:          aliases:
            - rmqnamesrv  rmqbroker:    image: foxiswho/rocketmq:broker    container_name: rmqbroker    ports:
      - 10909:10909
      - 10911:10911
    volumes:
      - ./logs:/opt/logs
      - ./store:/opt/store
      - ./conf/broker.conf:/etc/rocketmq/broker.conf    environment:        NAMESRV_ADDR: "rmqnamesrv:9876"
        JAVA_OPTS: " -Duser.home=/opt"
        JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
    command: mqbroker -c /etc/rocketmq/broker.conf    depends_on:
      - rmqnamesrv    networks:      rmq:        aliases:
          - rmqbroker  rmqconsole:    image: styletang/rocketmq-console-ng    container_name: rmqconsole    ports:
      - 8080:8080
    environment:        JAVA_OPTS: "-Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false"
    depends_on:
      - rmqnamesrv    networks:      rmq:        aliases:
          - rmqconsolenetworks:  rmq:    name: rmq    driver: bridge

然后在与docker-compose.yml同级下面相应的建立三个文件夹conflogsstore。然后在conf文件夹下面建立broker.conf配置文件,所有文件的目录位置如下所示。

docker-compose.ymlconf
	- broker.conflogsstore

然后在编写broker.conf配置文件里面的内容

# Licensed to the Apache Software Foundation (ASF) under one or more# contributor license agreements.  See the NOTICE file distributed with# this work for additional information regarding copyright ownership.# The ASF licenses this file to You under the Apache License, Version 2.0# (the "License"); you may not use this file except in compliance with# the License.  You may obtain a copy of the License at##     http://www.apache.org/licenses/LICENSE-2.0##  Unless required by applicable law or agreed to in writing, software#  distributed under the License is distributed on an "AS IS" BASIS,#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.#  See the License for the specific language governing permissions and#  limitations under the License.# 所属集群名字brokerClusterName=DefaultCluster# broker 名字,注意此处不同的配置文件填写的不一样,如果在 broker-a.properties 使用: broker-a,# 在 broker-b.properties 使用: broker-bbrokerName=broker-a# 0 表示 Master,> 0 表示 SlavebrokerId=0# nameServer地址,分号分割# namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876# 启动IP,如果 docker 报 com.alibaba.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.0.120:10909> failed# 解决方式1 加上一句 producer.setVipChannelEnabled(false);,解决方式2 brokerIP1 设置宿主机IP,不要使用docker 内部IPbrokerIP1=192.168.1.16# 在发送消息时,自动创建服务器不存在的topic,默认创建的队列数defaultTopicQueueNums=4# 是否允许 Broker 自动创建 Topic,建议线下开启,线上关闭 !!!这里仔细看是 false,false,falseautoCreateTopicEnable=true# 是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭autoCreateSubscriptionGroup=true# Broker 对外服务的监听端口listenPort=10911# 删除文件时间点,默认凌晨4点deleteWhen=04# 文件保留时间,默认48小时fileReservedTime=120# commitLog 每个文件的大小默认1GmapedFileSizeCommitLog=1073741824# ConsumeQueue 每个文件默认存 30W 条,根据业务情况调整mapedFileSizeConsumeQueue=300000# destroyMapedFileIntervalForcibly=120000# redeleteHangedFileInterval=120000# 检测物理文件磁盘空间diskMaxUsedSpaceRatio=88# 存储路径# storePathRootDir=/home/ztztdata/rocketmq-all-4.1.0-incubating/store# commitLog 存储路径# storePathCommitLog=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/commitlog# 消费队列存储# storePathConsumeQueue=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/consumequeue# 消息索引存储路径# storePathIndex=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/index# checkpoint 文件存储路径# storeCheckpoint=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/checkpoint# abort 文件存储路径# abortFile=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/abort# 限制的消息大小maxMessageSize=65536# flushCommitLogLeastPages=4# flushConsumeQueueLeastPages=2# flushCommitLogThoroughInterval=10000# flushConsumeQueueThoroughInterval=60000# Broker 的角色# - ASYNC_MASTER 异步复制Master# - SYNC_MASTER 同步双写Master# - SLAVEbrokerRole=ASYNC_MASTER# 刷盘方式# - ASYNC_FLUSH 异步刷盘# - SYNC_FLUSH 同步刷盘flushDiskType=ASYNC_FLUSH# 发消息线程池数量# sendMessageThreadPoolNums=128# 拉消息线程池数量# pullMessageThreadPoolNums=128

配置文件中的内容我们只需要改动一点即可,即brokerIP1 这个属性,我们将其更改为我们本机的ip,可以利用ipconfig进行查看。

修改完以后我们直接在docker-compose.yml文件所在的位置输入命令docker-compose up即可启动。启动成功以后在浏览器中输入http://localhost:8080/即可看到管理页面,就表示我们搭建成功了。

使用Springboot快速上手

这里将会使用 springboot 快速上手使用 mq,将会使用rocketmq-spring-boot-starter模块。郑州不孕不育医院哪家好:http://www.xbzztj.com/

pom 配置如下

<!--在pom.xml中添加依赖--><dependency>
    <groupid>org.apache.rocketmq</groupid>
    <artifactid>rocketmq-spring-boot-starter</artifactid>
    <version>2.0.3</version></dependency>

gradle配置如下

implementation 'org.apache.rocketmq:rocketmq-spring-boot-starter:2.0.3'

消费服务发送方配置如下:

## application.propertiesrocketmq.name-server=ip:9876rocketmq.producer.group=my-group

消费服务发送方程序如下:

@SpringBootApplicationpublic class ProducerApplication implements CommandLineRunner {    @Resource
    private RocketMQTemplate rocketMQTemplate;    public static void main(String[] args){
        SpringApplication.run(ProducerApplication.class, args);
    }    public void run(String... args) throws Exception {
        rocketMQTemplate.convertAndSend("test-topic-1", "Hello, World!");
        rocketMQTemplate.send("test-topic-1", MessageBuilder.withPayload("Hello, World! I'm from spring message").build());
    }

}

这里图省事的话可以将消费者和生产者写道同一个项目中。

消息消费方配置如下:

## application.propertiesrocketmq.name-server=ip:9876

消息消费方运行程序如下:

@SpringBootApplicationpublic class ConsumerApplication{    public static void main(String[] args){
        SpringApplication.run(ConsumerApplication.class, args);
    }    @Slf4j    @Service
    @RocketMQMessageListener(topic = "test-topic-1", consumerGroup = "my-consumer_test-topic-1")    public static class MyConsumer1 implements RocketMQListener<string> {        public void onMessage(String message) {
            log.info("received message: {}", message);
        }
    }
}

到现在为止我们就可以在本机上快乐的试验各种关于RocketMQ的相关东西了。

郑州的不孕不育医院哪家好:http://jbk.39.net/yiyuanfengcai/tsyl_zztjyy/3031/

大家可以直接从上面拉取项目,启动RocketMQ只需要两步。

  1. 修改broker.conf中的brokerIP1 参数,修改为本机IP

  2. 进入docker-compose.yml文件所在路径,执行docker-compose up命令即可

如果大家不想自己搭建Springboot项目的话,可以从https://github.com/modouxiansheng/Doraemon上面直接拉取下来就行了。</string>


本文转载自:https://blog.51cto.com/14510351/2487539

  • 浅析网站建设时如何降低网站跳出率
  • 网站建设规划应考虑哪些因素
  • 农业网站建设维护保养内容指哪些方面?
  • 网站建设后网站运营实战技巧二-如何打造高质量外链
  • 网站建设三部曲:域名程序+主机
  • 网站推广价格及渠道分析
  • seo网站推广,seo网络推广,seo推广优化
  • 解锁SEO实战密码60天网站流量提高20倍-效果监测
  • 您应该内部进行SEO优化还是将SEO外包?
  • SEO网站排名,大量页面不收录,实际案例分享与解决方案!
  • 我们在撰写SEO原创文章时容易犯哪些错误
  • SEO优化中的「坑」-“死链”
  • 每周分享(蜘蛛)在SEO中扮演的角色
  • 您访问的网站存在风险!
  • 如何向老板传达SEO优化的重要性?
  • SEO推广霸屏效果,站内优化功不可没
  • 网络推广和网络营销有什么区别-西安新新人类网络
  • 网络推广效果不好我们怎么来找原因
  • 郑州网络推广公司哪家强?
  • 每天一个网络推广秘籍,新浪微博加速提升企业广告效果
  • SEO 网站优化的步骤和技巧有哪些?(上)
  • 不懂SEO技术,该如何进行互联网营销?
  • Google 广告投放看不到成效?快来检查独立站 SEO 设置!
  • SEO排名优化萎靡不振?是和缘故?
  • SEO优化listing总优化不好?那是因为你不懂这件事!
  • 浅谈网站建设时重点是什么
  • 小溪畅流浅谈网站建设对公司发展起到了什么样的作用?
  • 河南平头哥霸屏网络推广:网站优化就是不断更新网站吗?
  • 新手在公司上班应该怎么去做好网络推广工作
  • 成都网络推广排名呼之欲出?站内优化是核心
  • 2020家居企业如何低成本通过“网络推广”新增客户实例问答
  • 企业网站优化,为什么SEO人员配置与培训很重要?
  • 选择SEO,还是付费推广?
  • SEO关键词排名该掌握的核心优化技巧
  • 为啥爆单总与你无缘?学会亚马逊SEO技巧,你早就成大卖了
  • 积累有价值的seo资源提高网站优化效果
  • SEO网站优化,新手SEO常犯的五个错误!
  • 渠成填补SEO空白 助行业生生不息
  • 为什么Google SEO见效慢
  • 一组图告诉你什么叫史上最全的SEO优化步骤