1.MQ-activemq学习笔记(上)
作者:互联网
学习资源:https://www.bilibili.com/video/BV164411G7aB?p=3
文章目录
MQ的产品学习说明
MQ消息中间件–>飞在天上的理念,必然有落地的实现。
目前同系列的MQ产品包括:kafka,rabbitmq,rocketmq,activemq,其他。
以activemq为例,他的技术维度包括:
- API 接受发送
- MQ 的高可用
- MQ 的集群容错配置
- MQ 的持久化
- 延时发送
- 签收机制
- Spring/SpringBoot 整合
- …
同理可得,其他mq产品,也有类似的技术内容。
用生活中的案例举例子
场景一:学生排队问老师题,一个需要问五分钟,后面的一直等待,效率低。
场景二:按照固定的格式,将问题整理成固定格式发给班长统一收集,然后去干自己的事,老师处理好了会联系。
为什么要使用 MQ ?
解决了耦合调用、异步模型、抵御洪峰流量,保护了主业务,消峰。
系统之间直接调用实际工程落地存在的问题?
造成三个严重的问题:
1.系统之间接口耦合严重
2.面对大流量并发时,容易被冲垮。
3.等待同步,存在性能问题
基于上述三个问题,必须有一种东西,可以达到下面的目标:
当然,这就是mq了。
MQ的作用定义
特点
采用异步模式处理
应用系统之间解耦
官网介绍、下载、安装
官网:http://activemq.apache.org/ 使用java的技术栈,中小型系统activemq够用了,大型的用阿里出品的rocketmq。
怎么玩?
- 最主要的功能就是实现高可用,高性能,可伸缩,易用,安全的企业级面向消息的系统。
- 异步消息的消费和处理
- 控制消息的消费顺序
- 可以和springboot整合简化代码
- 配置集群容错的mq集群。
linux下安装
- 官网下载
- 上传到linux的opt目录下,所有的第三方软件都往这里传。
- 解压缩到指定的文件安放位置。比如在根目录下新建myactivemq 文件夹。
解压之后就可以使用bin下面的文件启动了。
解压之后的mq内含的相关文件夹介绍
常用指令
active需要java环境才可以运行
切换到bin文件夹下之后,执行操作—>
普通启动、关闭、重启: ./activemq start/stop/restart
activemq的默认端口是61616.
还可以使用ps 命令查看进程是否启动了。
小技巧:屏蔽grep指令相关的进程
还可以通过网络查看61616端口是否被监听
netstat -anp | grep 61616
技巧:启动的时候可以把日志进行追加
控制台访问
访问之前先关闭防火墙,或者设置防火墙的访问白名单。这里直接关闭:
访问一下web管理站点测试一下:
两个重要的端口
- 8161端口提供管理控制台服务
- 61616端口提供jms服务
java编码mq标准api讲解
标签:java,61616,端口,笔记,mq,MQ,activemq 来源: https://blog.csdn.net/qq_25310669/article/details/110942993