linux系统下安装RocketMQ,启动,控制台连接,springboot整合简单使用

野性酷女 2023-07-25 14:04 11阅读 0赞

1.在安装RocketMQ之前需要安装JDK环境   [https://mp.csdn.net/console/editor/html/105397186][https_mp.csdn.net_console_editor_html_105397186]

2.下载liunx下的rocketMQ安装包    官网下载也慢,这里提供百度云地址

链接：https://pan.baidu.com/s/1tcwRF2C3lup\_88q\_TozqpA   
    提取码：ve1m   
3.将安装包拖到 /usr 目录下解压

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70][]

4.进入到bin目录,vi runserver.sh   编辑文件runserver.sh文件.RocketMQ默认启内存4G,这里修改调小一下.

![20200415140605839.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 1][]

5.继续修改配置,vi runbroker.sh ,默认8G ,这里需要调小,不然还是启动不了

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 2][]

6.先启动NameServer

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 3][]

7.启动broker连接到nameServer ,nameServer默认端口号9876

![20200417202947818.png][]

8.查看连接

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 4][]

9.使用开源框架连接rocketMQ,   rocket控制台 [https://github.com/apache/rocketmq-externals][https_github.com_apache_rocketmq-externals]

10.导入开源项目,连接rocket ,注意关闭防火墙 ,启动项目连接rocket

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 5][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 6][]

11.查看rocket控制台 .

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 7][]

### 12.springboot整合rocketmq简单使用 ###

1.pom.xml

<dependency>
                <groupId>org.apache.rocketmq</groupId>
                <artifactId>rocketmq-spring-boot-starter</artifactId>
                <version>2.0.3</version>
            </dependency>

2.application.properties配置文件

#服务端口
    server.port=8088
    #nameServer连接地址
    rocketmq.name-server=192.168.0.110:9876
    
    #分组 生产者必须要分组,才能拿到RocketMQTemplate模板
    rocketmq.producer.group=mayikt_producer

3.生产者

@RestController
    public class ProductController {
    
        @Autowired
        private RocketMQTemplate rocketMQTemplate;
    
        @RequestMapping("/sendOrder")
        public String sendOrder(){
            OrderEntity orderEntity=new OrderEntity("123456","zhangwudi");
            rocketMQTemplate.convertAndSend("mayikt-topic",orderEntity);
            return "success";
        }
    }

4.消费者

@Service
    @RocketMQMessageListener(topic = "mayikt-topic",consumerGroup = "mayikt_producer")
    public class OrderConsumer implements RocketMQListener<OrderEntity> {
    
        @Override
        public void onMessage(OrderEntity orderEntity) {
            System.out.println("orderEntity  :  "+orderEntity.toString());
        }
    }

5.测试

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 8][]

[https_mp.csdn.net_console_editor_html_105397186]: https://mp.csdn.net/console/editor/html/105397186
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70]: /images/20230528/a080b4f5cb1b40d89382352cd77a1362.png
[20200415140605839.png]: /images/20230528/e337ae0abdcf4f5ba551ad182402740c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 1]: /images/20230528/c6d89e6055374518a306bfa4296690b5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 2]: /images/20230528/1ea1149779ec4bed967df3940bd76794.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 3]: /images/20230528/59342d98a5d44ef4bdc81d38644d12d0.png
[20200417202947818.png]: /images/20230528/ba73b9dc760048d1a99cecf08e5145da.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 4]: /images/20230528/3543132257f24a6898d7ff1c68b01a0a.png
[https_github.com_apache_rocketmq-externals]: https://github.com/apache/rocketmq-externals
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 5]: /images/20230528/44b2983df7714e86a86e211fbac099f9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 6]: /images/20230528/adbd742431fd458f8c0d1a2a2a624d46.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 7]: /images/20230528/3c1eb4f104b5429386950bd196a30755.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdxaWFuZzE2OA_size_16_color_FFFFFF_t_70 8]: /images/20230528/36381e3ab3aa47bc892d2529549b658e.png