Java技术学习|消息队列|初级RabbitMQ

学习材料声明

黑马RabbitMQ快速入门教程,快速掌握rabbitmq、springAMQP消息中间件
是非常初级的学习,听说后续的高级课程会涉及到微服务之类的,所以等学完微服务再回来学。还有redis的高级部分也涉及了微服务,所以也都暂时停止学习了。

MQ是什么?

Message Queue。
为什么会出现这个,因为当请求很多,然后要完成这个请求,需要很多的可以细分的小服务组成,那么为了及时地响应请求,我们将串行执行的服务,分为一个服务(返回请求,发送消息给消息队列),消息队列(接受消息,发送消息给约定好的其他程序完成微服务!)
这样的改进,可以让请求快速得到响应,减少用户的等待时间,可以更好地拓展需求(增加约定好的程序),当部分程序宕机后,不影响其他部分。
这也是老师视频里面同步调用和异步调用的区别。
在这里插入图片描述
修改成:
在这里插入图片描述

常见的MQ技术

Rabbit ActiveMQ RocketMQ Kafka
在选型的时候,考虑到语言的可拓展,可靠,可用,延迟等等。

如何安装docker和rabbitMQ

我也不知道教程里面的命令要在哪里执行,就直接xshell连接虚拟机,复制粘贴,最后稀里糊涂安装好了。
安装教程1
安装教程2

这里还是遇到了一个问题:报错hmall不存在,是因为在docker network ls里面没有create过。所以这行命令直接删除。
外部还是访问不到,原因是防火墙没关

[root@user 公共]# docker run \
>  -e RABBITMQ_DEFAULT_USER=itheima \
>  -e RABBITMQ_DEFAULT_PASS=123321 \
>  -v mq-plugins:/plugins \
>  --name mq \
>  --hostname mq \
>  -p 15672:15672 \
>  -p 5672:5672 \
>  -d \
>  rabbitmq:3.8-managementsystemctl stop firewalld.service

第二天又不知道怎么启动rabbitMQ了。

慢慢懂了(docker存储镜像,镜像创建容器,容器就是一个又一个可以运行起来的程序。)

先看一下镜像还在不在?docker images
看一下容器是不是在运行? docker ps
镜像有,容器无,且docker run又说已有容器,就删除所有停止的容器,再docker run。最后关闭防火墙。
如何获取镜像和删除镜像
如何从已有镜像中创建容器

使用 docker container prune 命令删除所有停止的容器[root@user 公共]# docker run \
>  -e RABBITMQ_DEFAULT_USER=itheima \
>  -e RABBITMQ_DEFAULT_PASS=123321 \
>  -v mq-plugins:/plugins \
>  --name mq \
>  --hostname mq \
>  -p 15672:15672 \
>  -p 5672:5672 \
>  -d \
>  rabbitmq:3.8-managementsystemctl stop firewalld.service

如何访问?

页面上:图上的ip地址是自己的虚拟机地址。
在这里插入图片描述
java程序要访问:走的是5672端口。
在这里插入图片描述

比较不理解的virtual host这个概念

用于区分什么的?
一般是不同项目需要区分不同的虚拟主机。这样就看不到其他项目的队列,交换机之类的了。

SpringAMQP协议

将来我们开发业务功能的时候,肯定不会在控制台收发消息,而是应该基于编程的方式。由于RabbitMQ采用了AMQP协议,因此它具备跨语言的特性。任何语言只要遵循AMQP协议收发消息,都可以与RabbitMQ交互。并且RabbitMQ官方也提供了各种不同语言的客户端。
但是,RabbitMQ官方提供的Java客户端编码相对复杂,一般生产环境下我们更多会结合Spring来使用。而Spring的官方刚好基于RabbitMQ提供了这样一套消息收发的模板工具:SpringAMQP。并且还基于SpringBoot对其实现了自动装配,使用起来非常方便。

基础的模型

1.WorkQueues模型

在这里插入图片描述

2.交换机(可以复用消息给多个队列)

在这里插入图片描述

3.如何接受和发送的是Object类型

在这里插入图片描述

4.整个Java代码梳理

publisher:在配置文件中配置IP地址等等信息。发送消息。
consumer:同样需要配置信息,利用@RabbitListener来监听消息。会涉及交换机与队列的绑定代码。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://xiahunao.cn/news/2981724.html

如若内容造成侵权/违法违规/事实不符,请联系瞎胡闹网进行投诉反馈,一经查实,立即删除!

相关文章

【行为型模式】中介者模式

一、中介者模式概述 中介者模式定义:用一个中介对象来封装一系列的对象交互,中介者使各对象不需要显式地相互引用,从而使其耦合松散,而且可以独立地改变它们之间的交互。中介者模式又称为调停者模式。(对象行为型模式) 中介者模式…

autodl私有云使用方法(成员端使用)

此时找管理员添加进团队,https://private.autodl.com/访问,登录账号。可以看到容器实例。 点击创建实例,根据所需创建。版本号不可以超过最高的CUDA支持,可以自己拉取镜像。 此处需要注意数据盘使用量,密切关注。存取传…

web前端学习笔记2

2. 网页穿上美丽外衣 2.1 什么是CSS CSS (Cascading Style Sheets,层叠样式表),是一种用来为结构化文档(如 HTML 文档或 XML 应用)添加样式(字体、间距和颜色等)的计算机语言,CSS 文件扩展名为 .css。 CSS样式包括对字体、颜色、边距、高度、宽度、背景图片、网页定位…

MySQL数据库精讲001——概述

MySQL数据库精讲001——概述 文章目录 MySQL数据库精讲001——概述1.1 安装1.1.1 版本1.1.2 安装一、下载二、解压三、配置1. 添加环境变量2. 初始化MySQL3. 注册MySQL服务4. 启动MySQL服务5. 修改默认账户密码 四、登录MySQL五、卸载MySQL 1.1.3 连接1.1.4 企业使用方式(了解)…

绝缘栅型场效应管内部工作原理

我们以增强型nmos为例,其他mos管作为拓展理解: 1.各个部分介绍 如图,增强型nmos引出三个极,源极(Source),栅极(Gate),漏极(Drain)&am…

微博评论爬取

import requests import csv# 打开CSV文件以写入数据 f open(data.csv, modea, encodingutf-8-sig, newline) csv_writer csv.DictWriter(f, fieldnames[昵称, 性别, 归属地, 内容]) csv_writer.writeheader()# 定义一个函数用于获取评论内容 def GetContent(max_id):# 设置请…

【头文件】对.h文件的理解

目录 🌞1. 头文件的概念 🌊1.1 头文件的由来 🌊1.2 头文件的作用 🌊1.3 在.h文件中实现函数也不会出错的原因 🌞2. 简单示例 🌊2.1 头文件addition.h 🌊2.2 头文件接口实现addition.cpp …

网络编程 day5

select实现TCP并发服务器&#xff1a; #include<myhead.h> #define SER_IP "192.168.125.199" //服务器IP地址 #define SER_PORT 6666 //服务器端口号int main(int argc, const char *argv[]) {//1、创建套节字&#xff1a;用于接收…

页面分页打印,echarts图解决办法;生成PDF

1&#xff1a;echarts图片前端打印不是很完美&#xff0c;对于VUE2.0版本不是很有好 2&#xff1a;360浏览器不支持vue的最新版本的插件vue3-print-nb 3&#xff1a;vue-print-nb 可以打印带有echarts 一页内容&#xff0c;并且还存在bug&#xff0c;第一次点击打印没有&…

SVG 绘制微信订阅号icon

效果 代码 <!DOCTYPE html> <html> <body><svg xmlns"http://www.w3.org/2000/svg" version"1.1" width"600" height"600"><rect x"0" y"0" rx"0" ry"0" width&…

HarmonyOS开发案例:【图片编辑】

介绍 本篇Codelab是基于ArkTS的声明式开发范式的样例&#xff0c;主要介绍了图片编辑实现过程。样例主要包含以下功能&#xff1a; 图片的解码。使用PixelMap进行图片编辑&#xff0c;如裁剪、旋转、亮度、透明度、饱和度等。图片的编码。 相关概念 [图片解码]&#xff1a;读…

数学建模完整版

模型与适用题型 微分方程传染病预测模型 神经网络 层次分析法 粒子群算法 matlab 优劣解距离法

11 JavaScript学习:事件

Html事件 HTML 中有很多事件可以用来与用户交互&#xff0c;以下是一些常见的 HTML 事件及其详细解释和举例&#xff1a; click 事件&#xff1a;当用户点击元素时触发。 <button onclick"myFunction()">点击我</button>dblclick 事件&#xff1a;当用…

各平台奇怪问题备忘录

微信小程序 小程序报错Page 页面路径 has not been register yet 描述&#xff1a;uniapp做微信小程序开发时&#xff0c;新增某页面后&#xff0c;小程序跳转该页面报错Page 页面路径 has not been register yet 已知&#xff1a;page.json已添加该页面&#xff0c;小程序a…

游戏陪玩系统app

游戏陪玩系统APP为用户提供了一个便捷的平台&#xff0c;让他们能够轻松找到合适的陪玩者&#xff0c;一同享受游戏的乐趣。以下是对您提到的功能的详细解释&#xff1a; 游戏约玩&#xff1a; 在陪玩APP上&#xff0c;用户可以浏览陪玩者的信息&#xff0c;包括他们的游戏技能…

DNS 解析过程

一张图即可说明&#xff0c;如果能看到上图就不用往下看了。下面是上图的文字版解析 a. 用户输入 URL: 当你在浏览器中点击一个链接或输入一个网址时&#xff0c;比如点击一个图片链接 http://www.example.com/image.jpg&#xff0c;这个过程开始于你的设备尝试理解这个地址所…

Excel 冻结前几行

Excel中有冻结首航和冻结首列的选项&#xff0c;但是如果想冻结前几行该怎么操作&#xff1f; 冻结首行或冻结首列 视图 -> 冻结窗格 -> 冻结首行或冻结首列 冻结前几行或前几列 视图 -> 冻结窗格 -> 冻结拆分窗格 具体冻结几行和几列取决于当前选中的单元格。…

使用甘特图来做时间管理

在这个追求效率的时代,掌握高超的时间管理技能几乎等同于掌控了成功。事实上,时间就是金钱,更是稀缺资源。那么,如何高效地规划和利用时间呢?甘特图应该是您的必备武器之一。 甘特图(Gantt chart)名字虽然有些陌生,但它的使用范围确实广泛。无论是全职妈妈安排家务,还是上市公…

数据库轻松切换:解读Spring中的AbstractRoutingDataSource

欢迎来到我的博客&#xff0c;代码的世界里&#xff0c;每一行都是一个故事 数据库轻松切换&#xff1a;解读Spring中的AbstractRoutingDataSource 前言AbstractRoutingDataSource介绍作用和优势&#xff1a;作用&#xff1a;优势&#xff1a; 使用 AbstractRoutingDataSource …

flutter release 报错 Error: SocketException: Failed host lookup:

flutter 的 debug 模式没有任何问题 &#xff0c;打了release 包后一直报下面的错&#xff0c;查了一下是 因为没有网络权限 Error: SocketException: Failed host lookup: yomi-test-aws-sg.yomigame.games (OS Error: No address associated with hostname, errno 7) 按照下…