黑马程序员rocketmq第二章

这篇具有很好参考价值的文章主要介绍了黑马程序员rocketmq第二章。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

maven工程springboot-rocketmq-producer

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.1.RELEASE</version>
    </parent>

    <groupId>com.itheima.springboot</groupId>
    <artifactId>springboot-rocketmq-producer</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <rocketmq-spring-boot-starter-version>2.0.3</rocketmq-spring-boot-starter-version>
    </properties>


    <dependencies>
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
            <version>${rocketmq-spring-boot-starter-version}</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.6</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

    </dependencies>

</project>

application.properties

rocketmq.name-server=192.168.86.135:9876
rocketmq.producer.group=my-group
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class MQSpringBootApplication {

    public static void main(String[] args) {
        SpringApplication.run(MQSpringBootApplication.class);
    }


}

测试类

import cn.itcast.MQSpringBootApplication;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest(classes = {MQSpringBootApplication.class})
public class ProducerTest {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    @Test
    public void test1(){
        rocketMQTemplate.convertAndSend("springboot-mq","hello springboot rocketmq");
    }
}

springboot-rocketmq-consumer

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.itheima.springboot</groupId>
    <artifactId>springboot-rocketmq-consumer</artifactId>
    <version>1.0-SNAPSHOT</version>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.1.RELEASE</version>
    </parent>

    <properties>
        <rocketmq-spring-boot-starter-version>2.0.3</rocketmq-spring-boot-starter-version>
    </properties>


    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
            <version>${rocketmq-spring-boot-starter-version}</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.6</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

    </dependencies>

</project>

application.properties

rocketmq.name-server=192.168.86.135:9876
rocketmq.producer.group=my-group
package cn.itcast.mq;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

@Slf4j
@Component
@RocketMQMessageListener(topic = "springboot-mq",consumerGroup = "springboot-mq-consumer-1")
public class Consumer implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        System.out.println("接收到消息"+message);
        log.info("Receive message:"+message);
    }
}

package cn.itcast;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class MQSpringBootApplication {


    public static void main(String[] args) {
        SpringApplication.run(MQSpringBootApplication.class);
    }


}

2022-10-04 22:27:21.536  INFO 40552 --- [           main] cn.itcast.MQSpringBootApplication        : Started MQSpringBootApplication in 2.97 seconds (JVM running for 3.563)
接收到消息hello springboot rocketmq
2022-10-04 22:29:23.361  INFO 40552 --- [MessageThread_1] cn.itcast.mq.Consumer                    : Receive message:hello springboot rocketmq

zookeeper集群搭建
1.在/usr/soft/zookeeper-cluster下存放zookeeper-3.4.6.tar.gz
2.解压:tar -zvxf zookeeper-3.4.6.tar.gz
3./usr/soft/zookeeper-cluster/zookeeper-3.4.6/conf
下重命名 zoo_sample.cfg为zoo.cfg
mv zoo_sample.cfg zoo.cfg
4.创建三个文件夹
[root@java zookeeper-cluster]# mkdir zookeeper-1
[root@java zookeeper-cluster]# mkdir zookeeper-2
[root@java zookeeper-cluster]# mkdir zookeeper-3
[root@java zookeeper-cluster]# ls
zookeeper-1 zookeeper-2 zookeeper-3 zookeeper-3.4.6 zookeeper-3.4.6.tar.gz
5.将解压后的Zookeeper复制到以下三个目录
[root@java zookeeper-cluster]# cp -rf zookeeper-3.4.6 zookeeper-1
[root@java zookeeper-cluster]# cp -rf zookeeper-3.4.6 zookeeper-2
[root@java zookeeper-cluster]# cp -rf zookeeper-3.4.6 zookeeper-3
6.
配置每一个 Zookeeper 的 dataDir(zoo.cfg) clientPort 分别为 2181 2182 2183

修改zoo.cfg

clientPort=2181
dataDir=/usr/soft/zookeeper-cluster/zookeeper-1/data

​ 修改zoo.cfg

clientPort=2182
dataDir=/usr/soft/zookeeper-cluster/zookeeper-2/data

​ 修改zoo.cfg

clientPort=2183
dataDir=/usr/soft/zookeeper-cluster/zookeeper-3/data

········文章来源地址https://www.toymoban.com/news/detail-426016.html

到了这里,关于黑马程序员rocketmq第二章的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 【黑马程序员】机器学习

    一、机器学习算法分类 1、监督学习:         (1)目标值是类别:分类问题                         k-近邻算法、贝叶斯分类、决策树与随机森林、逻辑回归         (2)目标值是连续型的数据:回归问题                         线性回归、岭回归

    2024年02月07日
    浏览(57)
  • 黑马程序员 Docker笔记

    本篇学习笔记文档对应B站视频: 同学们,在前两天我们学习了Linux操作系统的常见命令以及如何在Linux上部署一个单体项目。大家想一想自己最大的感受是什么? 我相信,除了个别天赋异禀的同学以外,大多数同学都会有相同的感受,那就是麻烦。核心体现在三点: 命令太

    2024年01月23日
    浏览(69)
  • 【黑马程序员】PySpark学习

    定义:Apache Spark是用于大规模数据处理的统一分析引擎 简单来说,spark是一款分布式的计算框架,用于调度成百上千的服务器集群,计算PB、TB乃至EB级别的海量数据 Spark对Python语言的支持重点体现在Python第三方库:PySpark上 PySpark是由Spark官方开发的Python语言第三方库 Python开发

    2024年04月17日
    浏览(73)
  • Vector容器(黑马程序员)

    视频与文档链接 功能: vector数据结构和 数组非常相似 ,也称为 单端数组 普通数组一旦分配内存,容量就被固定了,无法扩展。 vector与普通数组区别: 不同之处在于数组是静态空间,而vector可以 动态扩展 动态扩展: 并不是在原空间之后续接新空间,而是找更大的内存空

    2024年02月08日
    浏览(46)
  • 谭浩强【C语言程序设计】第二章习题详解

      目录 ​编辑 1,什么是算法?试从日常生活中找3个例子,描述它们的算法。 2,什么叫结构化的算法?为什么要提倡结构化的算法? 3,试述3种基本结构的特点,请另外设计两种基本结构(要符合基本结构的特点)。 4,用传统流程图表示求解以下问题的算法。 (1)有两个

    2024年02月01日
    浏览(47)
  • 黑马程序员前端学习接口变更

    VUE 刘老师离职了,VUE的接口失效的,一律换为黑马官方接口 axios.defaults.baseURL = \\\'https://www.escook.cn\\\' 换成 axios.defaults.baseURL = \\\'https://applet-base-api-t.itheima.net\\\'    微信小程序 https://api-ugo-web.itheima.net https://www.uinav.com 刘老师博客简介为不再讲课的程序员,但他真的是一位不错的老师

    2024年02月09日
    浏览(53)
  • C++面向对象(黑马程序员)

    引用的本质:在C++内部实现是一个指针常量 C++面向对象三大特征:封装,继承,多态 公共权限 public 成员类内可以访问,类外可以访问 保护权限 protected 成员类内可以范文,类外不可以访问 私有权限 private 成员类内可以范文,类外不可以访问 保护权限和私有权限在继承中体

    2024年02月04日
    浏览(48)
  • [学习笔记]黑马程序员python教程

    1.9.1异常的捕获 1.9.1.1 为什么要捕获异常 1.9.1.2 捕获常规的异常 1.9.1.3 捕获指定的异常 e是接受异常信息的变量 1.9.1.4 捕获多个异常 1.9.1.5 捕获全部异常 1.9.1.6 异常的else 1.9.1.7 异常的finally 1.9.2 异常的传递 如果异常是在某一层产生,但是没有被catch,那么会继续往上层抛出,此

    2024年02月07日
    浏览(74)
  • SpringBoot-黑马程序员-学习笔记(三)

    目录 30.springboot整合MyBatis-plus 32.SSM整合 38.MP中的条件查询 小知识:许多放在类前面的注解,比如@Mapper,@Service都是将该类定义成一个Bean,交给spring管理 39.Service模块 1.创建普通springboot项目,勾选Mysql 框架 2.在pom包里面导入mybatis-plus的坐标 3.把数据层的类继承BaseMapper这个接口

    2024年02月07日
    浏览(50)
  • 学习笔记-微服务高级(黑马程序员)

    测试软件 jmeter 雪崩问题 个微服务往往依赖于多个其它微服务,服务提供者I发生了故障,依赖于当前服务的其它服务随着时间的推移形成级联失败 超时处理 设定超时时间,请求超过一定时间没有响应就返回错误信息 仓壁模式 限定每个业务能使用的线程数,避免耗尽整个tom

    2024年04月25日
    浏览(56)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包