基于RabbitMQ的简单应用(详解)

 更新时间:2017年11月17日 08:41:10   作者:未来有熊  
下面小编就为大家分享一篇基于RabbitMQ的简单应用(详解),具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧

虽然后台使用了读写分离技术,能够在一定程度上抗击高并发,但是如果并发量特别巨大时,主数据库不能同时处理高并发的请求,这时数据库容易宕机。

问题:

现在的问题是如何既能保证数据库正常运行,又能实现用户数据的入库操作?

解决方案:

引入rabbitMQ技术:

说明:

当数据库的访问压力过载时,这时会将过载以后的数据先保存到rabbitMQ中。其中的数据结构是队列的形式,先进先出。这时数据库从队列中取数据执行。一直到队列中的数据全部操作完成为止。

RabbitMQ就是消息的中间件。

RabbitMQ介绍:

RabbitMQ性能分析:

1.MSMQ:是微软的产品 应用于.net框架

2.ActiveMQ:是apache的产品 做业务用图广泛

3.RabbitQM:是爱立信的产品(早期手机生产厂商)基于erlang语言(函数式编程大数据 scala语言)

4.ZeroMQ:大数据中应用广泛,缺点容易丢失数据.但是业务系统中使用率较少

5.KafkaMQ:大数据项目中使用,50万/秒 现在主流

5.RabbitMQ环境搭建:

1.配置JDK:

2.固定虚拟机IP地址:

3.连接虚拟机:

编辑文件跳转路径:

Vim go

Cd /usr/local/src

2.安装rabbitMQ:

1.新建文件rabbitmq

/usr/local/src/rabbitmq

2.将安装文件导入

3.安装rabbitMQ

4.开启远程用户访问:

将文件复制到指定目录下:

cp /usr/share/doc/rabbitmq-server-3.6.1/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config

修改新复制的文件64行

1.将%%去掉

2.将,号去掉

修改为:

5.开启rabbitMQ:

执行命令:

rabbitmq-plugins enable rabbitmq_management

表示启动成功

6.开放端口15672和5672

iptables -I INPUT -p tcp --dport 15672 -j ACCEPT

访问rabbitMQ的控制台

iptables -I INPUT -p tcp --dport 5672 -j ACCEPT

程序连接rabbitMQ的端口

或者关闭防火墙

7.启动/停止服务

service rabbitmq-server start 启动

service rabbitmq-server stop 停止

service rabbitmq-server restart 重启

8.远程登录:

访问:

http://192.168.154.137:15672/

用户名和密码都是guest

9.视图解析:

10.建立管理员:

11.构建虚拟主机:

11.构建虚拟主机:

6.rabbitMQ的工作模式:

1.简单模式:

p:proverder 生产者

c:consumer 消费者

红色部分:队列 先进先出

原理说明:

生产者负责向队列中添加消息.消费者负责消费队列中的消息.

消费者通过监听器,实时监控消息队列.如果消息队列中有消息则消费,如果没有消息 则等待消息.

2.测试代码:

1.定义Connection

1.1.定义生产者

3.定义消费者:

2.工作模式:

原理说明:

生产者为消息队列中生产消息,多个消费者争抢执行权利,谁抢到谁执行.

实用场景:秒杀业务 抢红包等

测试代码:

3.发布订阅模式:

x:exchange 交换机

P:表示生产者

C1-2:表示多个消费者

原理说明:

当生产者生产消息后,先将消息发往交换机.交换机再将消息发往订阅了当前消息的队列,再次有各个队列的消费者执行.

类似于 广播

定义消费者::

4.路由模式:

x:表示交换机 type=direct 表示路由

路由模式中,需要定义路由key

原理说明:

1.当生产者发布消息时,会定义指定的路由key 例如 key:error

2.这时交换机会根据路由key发往满足条件的队列中.如果队列中没有符合条件的路由key将不能执行该消息.

5.主题模式:

Type:topic 表示主题模式

  • * (star) can substitute for exactly one word.
  • # (hash) can substitute for zero or more words.
  • 有坑 效果一样

7.订单实现RabbitMQ

1.引入配置文件:

classpath:jdbc.propertiesclasspath:env.properties /hp月n、 口山闰廷比二曰站叩四瞿二月当“习 classpath:rabbitmq.properties IUe> /value>" v:shapes="图片_x0020_42">

2.引入生产者

1.引入配置文件

2.定义发送端

3.发送端代码

通过代码相rabbitmq中发送数据

4.定义接收端:

引入配置文件

5.定义接收端:

6.测试成功

以上这篇基于RabbitMQ的简单应用(详解)就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • 开发工具EesyCode使用方法解析

    开发工具EesyCode使用方法解析

    这篇文章主要介绍了开发工具EesyCode使用方法解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-04-04
  • spring webflux自定义netty 参数解析

    spring webflux自定义netty 参数解析

    这篇文章主要介绍了spring webflux自定义netty 参数解析,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-09-09
  • spring声明式事务解析

    spring声明式事务解析

    这篇文章主要为大家详细介绍了spring声明式事务,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-10-10
  • Java 生成图片验证码3种方法(字母、加减乘除、中文)

    Java 生成图片验证码3种方法(字母、加减乘除、中文)

    这篇文章主要介绍了Java 生成图片验证码3种方法(字母、加减乘除、中文),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-01-01
  • SpringBoot整合Redis实现高并发数据缓存的示例讲解

    SpringBoot整合Redis实现高并发数据缓存的示例讲解

    这篇文章主要介绍了SpringBoot整合Redis实现高并发数据缓存,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-03-03
  • Java在Word中插入上标和下标的实现方法

    Java在Word中插入上标和下标的实现方法

    在某些情况下,你可能需要在Microsoft Word中插入上标和下标。例如,当你正在创建一个涉及科学公式的学术文件时,在这篇文章中,你将学习如何使用Spire.Doc for Java库在Word文档中插入上标和下标,需要的朋友可以参考下
    2022-10-10
  • 浅析java程序中hibernate的应用总结

    浅析java程序中hibernate的应用总结

    hibernate可以理解为是一个中间件它负责把java程序的sql语句接收过来发送到数据库,而数据库返回来的信息hibernate接收之后直接生成一个对象传给java
    2013-07-07
  • Spring Boot和Hazelcast使用详解

    Spring Boot和Hazelcast使用详解

    这篇文章主要介绍了Spring Boot和Hazelcast使用详解,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-09-09
  • Spring如何将bean添加到容器中

    Spring如何将bean添加到容器中

    这篇文章主要介绍了Spring如何将bean添加到容器中,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-05-05
  • 关于SpringBoot整合redis使用Lettuce客户端超时问题

    关于SpringBoot整合redis使用Lettuce客户端超时问题

    使用到Lettuce连接redis,一段时间后不操作,再去操作redis,会报连接超时错误,在其重连后又可使用,纠结是什么原因导致的呢,下面小编给大家带来了SpringBoot整合redis使用Lettuce客户端超时问题及解决方案,一起看看吧
    2021-08-08

最新评论