当前位置： 首页 > wzjs >正文

大连爱得科技网站建设公司怎么样政府免费培训面点班

wzjs 2025/8/18 13:35:29
大连爱得科技网站建设公司怎么样,政府免费培训面点班,品牌微信网站开发,做区块链网站需要注意哪些本文为个人云服务器上搭建RocketMQ教程，用于帮助大家降低安装学习成本，提高学习效率。本人在服务器上（我用的是阿里云服务器）安装MQ时遇到了大大小小的问题，因此在最终完成部署后，希望能总结一个教程&#…

        本文为个人云服务器上搭建RocketMQ教程，用于帮助大家降低安装学习成本，提高学习效率。本人在服务器上（我用的是阿里云服务器）安装MQ时遇到了大大小小的问题，因此在最终完成部署后，希望能总结一个教程，帮助大家一键高效完成部署。

在实际部署前，先带大家回顾一下RocketMQ的核心概念及工作流程。

RocketMQ核心概念：

  • NameServer：可以理解为是一个注册中心，主要是用来保存topic路由信息，管理Broker。在NameServer的集群中，NameServer与NameServer之间是没有任何通信的。
  • Broker：核心的一个角色，主要是用来保存topic的信息，接受生产者产生的消息，持久化消息。在一个Broker集群中，相同的BrokerName可以称为一个Broker组，一个Broker组中,BrokerId为0的为主节点，其它的为从节点。BrokerName和BrokerId是可以在Broker启动时通过配置文件配置的。每个Broker组只存放一部分消息。
  • 生产者：生产消息的一方就是生产者
  • 生产者组：一个生产者组可以有很多生产者，只需要在创建生产者的时候指定生产者组，那么这个生产者就在那个生产者组
  • 消费者：用来消费生产者消息的一方
  • 消费者组：跟生产者一样，每个消费者都有所在的消费者组，一个消费者组可以有很多的消费者，不同的消费者组消费消息是互不影响的。
  • topic（主题） ：可以理解为一个消息的集合的名字，生产者在发送消息的时候需要指定发到哪个topic下，消费者消费消息的时候也需要知道自己消费的是哪些topic底下的消息。
  • Tag（子主题） ：比topic低一级，可以用来区分同一topic下的不同业务类型的消息，发送消息的时候也需要指定。

工作流程

上面这张图很好的表示了RocketMQ的工作流程：

  • Broker启动的时候，会往每台NameServer（因为NameServer之间不通信，所以每台都得注册）注册自己的信息，这些信息包括自己的ip和端口号，自己这台Broker有哪些topic等信息。
  • Producer在启动之后会跟会NameServer建立连接，定期从NameServer中获取Broker的信息，当发送消息的时候，会根据消息需要发送到哪个topic去找对应的Broker地址，如果有的话，就向这台Broker发送请求；没有找到的话，就看根据是否允许自动创建topic来决定是否发送消息。
  • Broker在接收到Producer的消息之后，会将消息存起来，持久化，如果有从节点的话，也会主动同步给从节点，实现数据的备份
  • Consumer启动之后也会跟会NameServer建立连接，定期从NameServer中获取Broker和对应topic的信息，然后根据自己需要订阅的topic信息找到对应的Broker的地址，然后跟Broker建立连接，获取消息，进行消费。

根据以上工作流程可知，NamerServer会定期获取Broker的信息，并且Producer和Consumer在启动后都会和NameServer建立连接，因此在部署启动RocketMQ时需要先启动Name人Server，后启动Broker才可以。

环境搭建

        在简单介绍了RocketMQ的核心概念和工作流后，进入实际的部署环境。

        本文主要介绍使用Docker Compose进行安装，使用原始的拉取MQ包并进行解压缩运行的方法较为复杂，且原始的MQ配置中JVM的内存空间大小是8g，也需要修改对应的配置，因此不推荐该方法。而使用docker方式也可以，但需要分别拉取NameServer、Broker和DashBoa的镜像再运行，有点麻烦，不如Docker Compose通过编写Docker Compose.yaml配置文件进行运行来的方便快捷。

1. 准备

        在实际安装MQ之前，需要有一些前提准备工作（基础环境搭建）：

  • 关闭防火墙
systemctl stop firewalld
systemctl disable firewalld
  • 安装好JDK，因为RockerMQ是使用Java编写的，且后续的RocketMQ的Web可视化管理页面DashBoard也是使用Spring写的，因此需要有Java运行环境。
//查看JDK版本（最好在1.8以上，因为1.8稳定）
java -version

  • 安装好了Docker及Docker-Compose

Docker和Docker-Compose的作用：

  • Docker：Docker 是一个容器化平台，专注于管理单个容器。每次您启动一个 Docker 容器时，都需要使用 docker run 命令手动指定所有容器的配置。
  • Docker Compose：Docker Compose 用于定义和运行多容器应用。它使得管理多个容器变得简单，通过编写 docker-compose.yml 文件来配置所有容器，然后用 docker-compose 命令来管理这些容器。
    //查询docker版本
docker -v
//查询docker-compose版本
docker-compose -v

    • 创建好对应的文件：分别创建rocketmq文件夹，conf文件夹和broker.conf及docker-compose.yml配置文件。

    2. 修改具体配置文件

    • 修改broker.conf配置文件
    //进入对应的conf文件夹下
cd /usr/local/rocketmq/conf
//修改配置文件
vim broker.conf

    broker配置文件如下：

    brokerClusterName = DefaultCluster

    brokerName = broker-a

    brokerId = 0

    deleteWhen = 04

    fileReservedTime = 48

    brokerRole = ASYNC_MASTER

    flushDiskType = ASYNC_FLUSH

    # 如果是本地程序调用云主机 mq，这个需要设置成 云主机 IP

    # 如果Docker环境需要设置成宿主机IP

    brokerIP1 = {docker宿主机IP地址}

    • 修改docker-compose.yaml配置文件
    //进入对应的conf文件夹下
cd /usr/local/rocketmq/conf
//修改配置文件
vim docker-compose.yaml

    docker-compose.yaml配置文件如下：

    version: '3.5'
    services:
      namesrv:
        image: apache/rocketmq:5.2.0
        container_name: rmqnamesrv
        ports:
          - "9876:9876"
        command: sh mqnamesrv
        environment:
          - JAVA_OPT_EXT=-Xms128m -Xmx128m -Xmn128m
        networks:
            rmq:
              aliases:
                - rmqnamesrv

      broker:
        image: apache/rocketmq:5.2.0
        container_name: rmqbroker
        ports:
          - "10909:10909"
          - "10911:10911"
        depends_on:
          - namesrv
        volumes:
          - ./conf/broker.conf:/opt.rocketmq-5.2.0/conf/broker.conf
        command: sh mqbroker -c /opt.rocketmq-5.2.0/conf/broker.conf
        environment:
          NAMESRV_ADDR: "rmqnamesrv:9876"
          JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
        networks:
          rmq:
            aliases:
              - rmqbroker

      mqconsole:
        image: apacherocketmq/rocketmq-dashboard
        container_name: rmqconsole
        ports:
          - 8080:8080
        depends_on:
          - namesrv
        environment:
            JAVA_OPTS: "-Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false"
        networks:
          rmq:
            aliases:
              - rmqconsole

    networks:
      rmq:
        name: rmq
        driver: bridge

            这里简单说明一下这个配置文件的内容及作用：里面分别介绍了namesrv、broker和mqconsole镜像的名称、容器名称、环境、端口及网络配置等，根据该配置文件，可拉取对应的镜像并构建容器，command: sh mqbroker -c /opt.rocketmq-5.2.0/conf/broker.conf命令的作用是根据刚修改的broker.conf来运行。

    3. 运行docker-compose.yaml

            在完成以上内容后，就可以运行docker-compose.yaml，它会拉取对应的镜像并构建容器运行。如果拉取失败也可以自己把上面所需的三个镜像拉取下来，再运行该文件。

    //进入含有docker-compose.yaml的文件夹下
cd /usr/local/rocketmq/conf
//启动docker-compose
docker-compose up
//上面的命令为前台启动，可以直接看到启动过程和可能出现的错误
docker-compose up -d
//上面的命令为后台启动

    启动后的界面：

    当显示以上界面时说明启动成功，输入http://主机ip:8080后若能成功访问说明部署成功。

            如果MQ启动成功了，但是无法打开网页，有可能是服务器对应的安全组没有设置，记得把10909、10911、9876打开。

            以上就是MQ的所有部署安装教程啦，祝大家都能找到满意的offer~

    http://www.dtcms.com/wzjs/392850.html

    相关文章：

  • 内部网站制作推广app用什么平台比较好
  • Editplus做网站电商网站开发平台有哪些
  • 室内设计效果图手机软件哈尔滨网站优化流程
  • 怎么做产品网站推广关键词你们懂的
  • 洛阳做网站公司电话免费一键生成个人网站
  • 宝鸡网站建设为微信推广软件哪个好
  • 织梦网站模板怎么做优化技术
  • 做钓鱼网站会被抓吗seo搜索引擎是什么意思
  • 做网站得叫什么软件免费网站友情链接
  • 网站创建的一般步骤二维码引流推广的平台
  • 字体设计图片优化师培训机构
  • 国内做网站大公司有哪些企业网站制作哪家好
  • 网站建设的费用百度点击器下载
  • 在职考研哪个网站做的好百度账号注册申请
  • 广州网站设计公司招聘宁波seo行者seo09
  • 网站里的横幅广告怎么做中文网站排名
  • 关于政府网站群建设的咨询函中国seo网站
  • 网站模板 寻模板网站流量统计查询
  • 可以在自己的电脑上做网站吗广州网站建设工作室
  • 自己做网站实时监控中国十大软件外包公司
  • 佛山外贸网站建设方案国内疫情最新情况
  • 宣传片拍摄脚本模板东莞做网站seo
  • 网站建设一定要公司吗邯郸seo优化
  • 厦门网站seo建设上海网站建设服务
  • 什么软件可以做动漫视频网站教育培训机构有哪些
  • qq网站在线登录网页版山东网站seo
  • 如何用华为云服务器做网站软件外包平台
  • 上海企业网站建设公司2020最近的新闻大事10条
  • 佛山市网站建设公司渠道推广费用咨询
  • 赤峰建设局网站销售网站有哪些