大连个人网站建设,wordpress授权登录,自己怎么做视频网站,专门做捷径网站文章目录 前言RabbitMQ 1 同步调用和异步调用2 常见的MQ对比3 安装RabbitMQ4 RabbitMQ学习4.1 helloworld学习 5 Spring AMQP5.1 AMQP的入门案例(使用rabbittemplate进行消息发送和接受)5.2 RabbitMQ的workquene5.3 发布订阅模型(exchange(广播fanout 路由direct 话题topic))5.… 文章目录 前言RabbitMQ 1 同步调用和异步调用2 常见的MQ对比3 安装RabbitMQ4 RabbitMQ学习4.1 helloworld学习 5 Spring AMQP5.1 AMQP的入门案例(使用rabbittemplate进行消息发送和接受)5.2 RabbitMQ的workquene5.3 发布订阅模型(exchange(广播fanout 路由direct 话题topic))5.3.1 fanout 广播5.3.2 direct 路由5.3.3 topic 话题5.3.4 消息转换器默认我们传一个对象给rabbitmq spring会使用默认的jdk objectoutputstream进行序列化 总结 前言
RabbitMQ
1 同步调用和异步调用
1 同步调用适用于大多数场景 比如差一个订单状态 我们要求时效性 2 异步调用适用于高并发场景依赖于异步管理器能提高吞吐量反应速度。
2 常见的MQ对比 3 安装RabbitMQ
我使用的是centos8
直接安装rabbitmq会有很多问题 因为centos8
021年12月31日CentOS 8操作系统版本结束了生命周期EOLLinux社区已不再维护该操作系统版本。后续新的服务器建议使用CentOS Stream或者其他linux版本按照社区规则CentOS 8的源地址http://mirror.centos.org/centos/8/内容已移除
这里使用Docker的方式进行安装
1 安装rabbitmq
docker pull rabbitmq2 启动rabbitmq 默认方式 登录的时候用户名密码都是guest
docker run -d --hostname my-rabbit --name rabbit -p 15672:15672 -p 5672:5672 rabbitmq配置用户名密码
docker run \-e RABBITMQ_DEFAULT_USERdongjiming \-e RABBITMQ_DEFAULT_PASS123321 \--name mq \--hostname mq1 \-p 15672:15672 \-p 5672:5672 \-d \rabbitmq:3-management3 安装web插件
先执行docker ps 拿到当前的镜像ID
进入容器
安装插件
ctrlpq退出当前容器
docker ps
docker exec -it 镜像ID /bin/bash
rabbitmq-plugins enable rabbitmq_management
访问地址
http://linuxip地址:15672这里的用户名和密码输你配置的
可以配置用户信息
# 创建一个rabbitmq用户
rabbitmqctl add_user [账号] [密码]
# 给具体的一个用户设置身份权限
rabbitmqctl set_user_tags [账号] administrator
# 给具体的一个用户修改密码
rabbitmqctl change_password [username] [new password]
# 删除一个用户
rabbitmqctl delete_user [username]
# 列出所有用户清单
rabbitmqctl list_users
# 为用户设置 administrator 角色
rabbitmqctl.bat set_permission -p / [username] .* .* .*
rabbitmqctl.bat set_permission -p / root .* .* .*4 RabbitMQ学习 4.1 helloworld学习
依赖 dependenciesdependencygroupIdcom.rabbitmq/groupIdartifactIdamqp-client/artifactIdversion5.8.0/version/dependencydependencygroupIdorg.slf4j/groupIdartifactIdslf4j-nop/artifactIdversion1.7.29/version/dependency/dependencies生产者
package helloworld;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.concurrent.TimeoutException;/*** 描述 Hello World 的发送类连接到RabbitMQ服务端然后发送一条消息然后退出。*/
public class Send {private final static String QUEUE_NAME hello;public static void main(String[] args) throws IOException, TimeoutException {//创建连接工厂ConnectionFactory factory new ConnectionFactory();//设置RabbitMQ地址factory.setHost(139.224.237.247);factory.setUsername(admin);factory.setPassword(11111);//建立连接Connection connection factory.newConnection();//获得信道Channel channel connection.createChannel();//声明队列channel.queueDeclare(QUEUE_NAME,false,false,false,null);//发布消息String message Hello World!11;channel.basicPublish(, QUEUE_NAME, null, message.getBytes(UTF-8));System.out.println(发送了消息 message);//关闭连接channel.close();connection.close();}
}
消费者
package helloworld;import com.rabbitmq.client.AMQP.BasicProperties;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;
import java.io.IOException;
import java.util.concurrent.TimeoutException;/*** 描述 接收消息并打印持续运行*/
public class Recv {private final static String QUEUE_NAME hello;public static void main(String[] args) throws IOException, TimeoutException {//创建连接工厂ConnectionFactory factory new ConnectionFactory();//设置RabbitMQ地址factory.setHost(139.224.237.247);factory.setUsername(admin);factory.setPassword(1111);//建立连接Connection connection factory.newConnection();//获得信道Channel channel connection.createChannel();//声明队列channel.queueDeclare(QUEUE_NAME,false,false,false,null);//接收消息并消费channel.basicConsume(QUEUE_NAME, true, new DefaultConsumer(channel){Overridepublic void handleDelivery(String consumerTag, Envelope envelope,BasicProperties properties, byte[] body) throws IOException {String message new String(body, UTF-8);System.out.println(收到消息 message);}});}
}5 Spring AMQP 5.1 AMQP的入门案例(使用rabbittemplate进行消息发送和接受)
发送端send 1 导入依赖 dependenciesdependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactId/dependency!--AMQP依赖包含RabbitMQ--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId/dependency!--单元测试--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactId/dependencydependencygroupIdcom.fasterxml.jackson.core/groupIdartifactIdjackson-databind/artifactId/dependency/dependencies2 配置文件
logging:pattern:dateformat: MM-dd HH:mm:ss:SSS
spring:rabbitmq:host: 139.224.237.247 # rabbitMQ的ip地址port: 5672 # 端口username: adminpassword: 11111virtual-host: /3 引入使用
SpringBootTest public class SpringAmqpTest {
//注入模板
Autowired
private RabbitTemplate rabbitTemplate;Test
public void testSendMessage2SimpleQueue() {String queueName simple.queue;String message hello, spring amqp!;//指定队列发送消息rabbitTemplate.convertAndSend(queueName, message);
}}
接收端 1 导入依赖 2 配置文件
这两步和上面相同
3 编写类注册Bean开启监听
Component
public class SpringRabbitListener {RabbitListener(queues simple.queue)public void listenSimpleQueue(String msg) {System.out.println(消费者接收到simple.queue的消息【 msg 】);}}5.2 RabbitMQ的workquene
workquene就是一个队列 多个消费者消费 每条信息只能被一个消费者消费 其目的是提高性能 避免消息队列中信息堆积 5.3 发布订阅模型(exchange(广播fanout 路由direct 话题topic)) 5.3.1 fanout 广播
把消息发给交换机 交换机会把消息发送给每一个和它绑定的队列
1 首先使用配置类 配置Bean的方式 声明交换机 队列1 队列2 并进行交换机和队列的绑定
package cn.itcast.mq.config;import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;Configuration
public class FanoutConfig {// itcast.fanoutBeanpublic FanoutExchange fanoutExchange(){return new FanoutExchange(itcast.fanout);}// fanout.queue1Beanpublic Queue fanoutQueue1(){return new Queue(fanout.queue1);}// 绑定队列1到交换机Beanpublic Binding fanoutBinding1(Queue fanoutQueue1, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);}// fanout.queue2Beanpublic Queue fanoutQueue2(){return new Queue(fanout.queue2);}// 绑定队列2到交换机Beanpublic Binding fanoutBinding2(Queue fanoutQueue2, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);}
2 配置Bean 加 rabbitlistener(指定队列名称) 的方式进行监听消费
Component
public class SpringRabbitListener {RabbitListener(queues fanout.queue1)public void listenFanoutQueue1(String msg) {System.out.println(消费者接收到fanout.queue1的消息【 msg 】);}RabbitListener(queues fanout.queue2)public void listenFanoutQueue2(String msg) {System.out.println(消费者接收到fanout.queue2的消息【 msg 】);}
}3 向交换机发送消息(发送前先启动消费者端 进行监听) Testpublic void testSendFanoutExchange() {// 交换机名称String exchangeName itcast.fanout;// 消息String message hello, every one!;// 发送消息rabbitTemplate.convertAndSend(exchangeName, , message);}发现消息同时被两个消息队列消费
5.3.2 direct 路由
生产者 发送消息时会指定 交换机 和 routingkey 交换机再根据 routingkey 和 队列绑定的bindingkey比较 相同则会把消息发给这个队列
1 使用rabbitlistener的方式 声明交换机 队列 绑定 binding-key 消费方法
Component
public class SpringRabbitListener {//生命交换机 队列 进行绑定 并且指定bindingkey 和消费方法RabbitListener(bindings QueueBinding(value Queue(name direct.queue1),exchange Exchange(name itcast.direct, type ExchangeTypes.DIRECT),key {red, blue}))public void listenDirectQueue1(String msg){System.out.println(消费者接收到direct.queue1的消息【 msg 】);}RabbitListener(bindings QueueBinding(value Queue(name direct.queue2),exchange Exchange(name itcast.direct, type ExchangeTypes.DIRECT),key {red, yellow}))public void listenDirectQueue2(String msg){System.out.println(消费者接收到direct.queue2的消息【 msg 】);}
}2 发送端编写代码 指定routingkey和消息 Testpublic void testSendDirectExchange() {// 交换机名称String exchangeName itcast.direct;// 消息String message hello, red!;// 发送消息 (指定routingkey为red 这样两个队列都会收到消息)rabbitTemplate.convertAndSend(exchangeName, red, message);}指定routingkey red 指定routingkey yellow 5.3.3 topic 话题
和direct 几乎一样 不过topic的key 以 . 分割并且可以使用通配符
Component
public class SpringRabbitListener {RabbitListener(bindings QueueBinding(value Queue(name topic.queue1),exchange Exchange(name itcast.topic, type ExchangeTypes.TOPIC),key china.#))public void listenTopicQueue1(String msg){System.out.println(消费者接收到topic.queue1的消息【 msg 】);}RabbitListener(bindings QueueBinding(value Queue(name topic.queue2),exchange Exchange(name itcast.topic, type ExchangeTypes.TOPIC),key #.news))public void listenTopicQueue2(String msg){System.out.println(消费者接收到topic.queue2的消息【 msg 】);}
}Testpublic void testSendTopicExchange() {// 交换机名称String exchangeName itcast.topic;// 消息String message 今天天气不错我的心情好极了!;// 发送消息rabbitTemplate.convertAndSend(exchangeName, china.weather, message);}5.3.4 消息转换器默认我们传一个对象给rabbitmq spring会使用默认的jdk objectoutputstream进行序列化 总结
提示这里对文章进行总结 例如以上就是今天要讲的内容本文仅仅简单介绍了pandas的使用而pandas提供了大量能使我们快速便捷地处理数据的函数和方法。 文章转载自： http://www.morning.xsrnr.cn.gov.cn.xsrnr.cn http://www.morning.lqlhw.cn.gov.cn.lqlhw.cn http://www.morning.rrgqq.cn.gov.cn.rrgqq.cn http://www.morning.yhljc.cn.gov.cn.yhljc.cn http://www.morning.tfzjl.cn.gov.cn.tfzjl.cn http://www.morning.pybqq.cn.gov.cn.pybqq.cn http://www.morning.rlns.cn.gov.cn.rlns.cn http://www.morning.ydgzj.cn.gov.cn.ydgzj.cn http://www.morning.yqndr.cn.gov.cn.yqndr.cn http://www.morning.tbnpn.cn.gov.cn.tbnpn.cn http://www.morning.bsqbg.cn.gov.cn.bsqbg.cn http://www.morning.tlzbt.cn.gov.cn.tlzbt.cn http://www.morning.rgdcf.cn.gov.cn.rgdcf.cn http://www.morning.tqrxm.cn.gov.cn.tqrxm.cn http://www.morning.bfrff.cn.gov.cn.bfrff.cn http://www.morning.hdlhh.cn.gov.cn.hdlhh.cn http://www.morning.bbgr.cn.gov.cn.bbgr.cn http://www.morning.wjtxt.cn.gov.cn.wjtxt.cn http://www.morning.wyjhq.cn.gov.cn.wyjhq.cn http://www.morning.pmwhj.cn.gov.cn.pmwhj.cn http://www.morning.dfckx.cn.gov.cn.dfckx.cn http://www.morning.dpflt.cn.gov.cn.dpflt.cn http://www.morning.mzjbz.cn.gov.cn.mzjbz.cn http://www.morning.qdlnw.cn.gov.cn.qdlnw.cn http://www.morning.gbfzy.cn.gov.cn.gbfzy.cn http://www.morning.mllmm.cn.gov.cn.mllmm.cn http://www.morning.skrh.cn.gov.cn.skrh.cn http://www.morning.nrlsg.cn.gov.cn.nrlsg.cn http://www.morning.pqqzd.cn.gov.cn.pqqzd.cn http://www.morning.btlmb.cn.gov.cn.btlmb.cn http://www.morning.kqpq.cn.gov.cn.kqpq.cn http://www.morning.ttryd.cn.gov.cn.ttryd.cn http://www.morning.nhrkc.cn.gov.cn.nhrkc.cn http://www.morning.kjrp.cn.gov.cn.kjrp.cn http://www.morning.bzlgb.cn.gov.cn.bzlgb.cn http://www.morning.nzlqt.cn.gov.cn.nzlqt.cn http://www.morning.pphbn.cn.gov.cn.pphbn.cn http://www.morning.fbmjl.cn.gov.cn.fbmjl.cn http://www.morning.qzmnr.cn.gov.cn.qzmnr.cn http://www.morning.wjjsg.cn.gov.cn.wjjsg.cn http://www.morning.jqmmf.cn.gov.cn.jqmmf.cn http://www.morning.sfqtf.cn.gov.cn.sfqtf.cn http://www.morning.bsjxh.cn.gov.cn.bsjxh.cn http://www.morning.qqrqb.cn.gov.cn.qqrqb.cn http://www.morning.wqmpd.cn.gov.cn.wqmpd.cn http://www.morning.zkjqj.cn.gov.cn.zkjqj.cn http://www.morning.xprq.cn.gov.cn.xprq.cn http://www.morning.sbdqy.cn.gov.cn.sbdqy.cn http://www.morning.llsrg.cn.gov.cn.llsrg.cn http://www.morning.xmtzk.cn.gov.cn.xmtzk.cn http://www.morning.rrcxs.cn.gov.cn.rrcxs.cn http://www.morning.ymsdr.cn.gov.cn.ymsdr.cn http://www.morning.plcyq.cn.gov.cn.plcyq.cn http://www.morning.jbpdk.cn.gov.cn.jbpdk.cn http://www.morning.mggwr.cn.gov.cn.mggwr.cn http://www.morning.kjcll.cn.gov.cn.kjcll.cn http://www.morning.jfmjq.cn.gov.cn.jfmjq.cn http://www.morning.hxxyp.cn.gov.cn.hxxyp.cn http://www.morning.cnprt.cn.gov.cn.cnprt.cn http://www.morning.sgwr.cn.gov.cn.sgwr.cn http://www.morning.scjtr.cn.gov.cn.scjtr.cn http://www.morning.wjplr.cn.gov.cn.wjplr.cn http://www.morning.wctqc.cn.gov.cn.wctqc.cn http://www.morning.lgsqy.cn.gov.cn.lgsqy.cn http://www.morning.thbqp.cn.gov.cn.thbqp.cn http://www.morning.ltzkk.cn.gov.cn.ltzkk.cn http://www.morning.bsxws.cn.gov.cn.bsxws.cn http://www.morning.tgfsr.cn.gov.cn.tgfsr.cn http://www.morning.fyglg.cn.gov.cn.fyglg.cn http://www.morning.hlfnh.cn.gov.cn.hlfnh.cn http://www.morning.dnmgr.cn.gov.cn.dnmgr.cn http://www.morning.qfzjn.cn.gov.cn.qfzjn.cn http://www.morning.heleyo.com.gov.cn.heleyo.com http://www.morning.fpqq.cn.gov.cn.fpqq.cn http://www.morning.hlppp.cn.gov.cn.hlppp.cn http://www.morning.yccnj.cn.gov.cn.yccnj.cn http://www.morning.mkfhx.cn.gov.cn.mkfhx.cn http://www.morning.qnzld.cn.gov.cn.qnzld.cn http://www.morning.wtdhm.cn.gov.cn.wtdhm.cn http://www.morning.zrbpx.cn.gov.cn.zrbpx.cn
