当前位置： 首页 > wzjs >正文

交互做的好网站怎么用ppt做网站设计

wzjs 2025/9/11 15:17:17
交互做的好网站,怎么用ppt做网站设计,24小时自助建站,大学生自学网前言 在 RabbitMQ 中，一共有七种工作模式，我们也可以打开官网了解： 本章我们先介绍前三种工作模式 （Simple）简单模式 P：producer 生产者，负责发送消息 C：consumer 消费者&#x…

前言

在 RabbitMQ 中，一共有七种工作模式，我们也可以打开官网了解：
在这里插入图片描述

本章我们先介绍前三种工作模式

（Simple）简单模式

在这里插入图片描述

P：producer 生产者，负责发送消息
C：consumer 消费者，接收消息
Queue: 消息队列

简单模式的特点：一个生产者P，一个消费者C，消息只能被消费一次，也被称为点对点【Point-to-Point】模式

案例：上一篇文章中的快速入门RabbitMQ 就是简单模式的演示，大家可以去看一下代码的实现

Work Queue（工作队列）

在这里插入图片描述
特点：多个消费者共同消费同一条队列的消息，消息不重复
假设队列有 10 条消息，C1 消费了 4 条，C2 消费了 6 条，这就是共同消费。

生产者：

public class Producer {public static void main(String[] args) throws IOException, TimeoutException {//进行绑定ConnectionFactory factory = new ConnectionFactory();factory.setHost(Constants.HOST);factory.setPort(Constants.PORT);factory.setUsername(Constants.NAME);factory.setPassword(Constants.PASSWORD);factory.setVirtualHost(Constants.VIRTUAL_HOST);//建立连接Connection connection = factory.newConnection();//开启信道Channel channel = connection.createChannel();//这里使用默认的交换机//声明队列channel.queueDeclare(Constants.WORK_QUEUE, true, false, false, null);//发送消息for (int i = 0; i < 10; i++) {String msg = "hello work queue...."+i;channel.basicPublish("",Constants.WORK_QUEUE, null, msg.getBytes());}System.out.println("发送消息成功");//资源释放channel.close();connection.close();}
}

消费者：

public class Consumer1 {public static void main(String[] args) throws IOException, TimeoutException {//进行参数绑定ConnectionFactory factory = new ConnectionFactory();factory.setHost(Constants.HOST);factory.setPort(Constants.PORT);factory.setUsername(Constants.NAME);factory.setPassword(Constants.PASSWORD);factory.setVirtualHost(Constants.VIRTUAL_HOST);//建立连接Connection connection = factory.newConnection();//开启信道Channel channel = connection.createChannel();//使用默认的交换机//声明队列channel.queueDeclare(Constants.WORK_QUEUE, true, false, false, null);//消息消费DefaultConsumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println("接收到的消息：" + new String(body));}};channel.basicConsume(Constants.WORK_QUEUE, true, consumer);}
}

public class Consumer2 {public static void main(String[] args) throws IOException, TimeoutException {//进行参数绑定ConnectionFactory factory = new ConnectionFactory();factory.setHost(Constants.HOST);factory.setPort(Constants.PORT);factory.setUsername(Constants.NAME);factory.setPassword(Constants.PASSWORD);factory.setVirtualHost(Constants.VIRTUAL_HOST);//建立连接Connection connection = factory.newConnection();//开启信道Channel channel = connection.createChannel();//使用默认的交换机//声明队列channel.queueDeclare(Constants.WORK_QUEUE, true, false, false, null);//消息消费DefaultConsumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println("接收到的消息：" + new String(body));}};channel.basicConsume(Constants.WORK_QUEUE, true, consumer);}
}

交换机概念

这里解释一下为什么上面两种工作模式流程图没有交换机的存在，因为交换机在上面两种工作模式中不起重要作用，为了简化，所以省略了交换机，实际在 RabbitMQ 中 生产者发送的消息是需要通过交换机将消息发送到对应的队列中。

在RabbitMQ 中，一共有四种类型的交换机，分别是 Fanout、Direct、Topic、Headers，不同类型的交换机有着不同的路由策略。
在 AMQP 协议中还有额外的两种类型：System 和 自定义，在RabbitMQ 中我们就不介绍这额外的两种

Fanout：广播模式，将小心发送给所有与该交换机绑定的队列中，对应下面即将讲解的 Publish / Subscribe (发布 / 订阅) 工作模式

Direct：定向，将消息发送给指定的 routing key 的队列中，对应 Routing 模式

Topic：通配符，将消息交给符合指定的 routing pattern （路由模式）的队列

Headers : 该交换机不依赖路由键的批匹配规则来路由消息，而是根据发送的消息内容中的headers 属性进行匹配，headers 类型的交换机性能很差，很少很在工作中遇到。

这里解释一下 routing key 和 binding key 的概念：

在这里插入图片描述

生产者和交换机的联系使用的是 Routing Key，交换机和队列的联系使用的是 Binding Key

在后续的代码中 我们也会将 Binding Key 当作 Routing Key

Publish / Subscribe (发布 / 订阅)

在这里插入图片描述

交换机将消息发送到不同的队列中，类似广播的作用，所有和该交换机绑定的队列都会收到一样的消息

public class Producer {public static void main(String[] args) throws IOException, TimeoutException {//设置 MQ 参数ConnectionFactory factory = new ConnectionFactory();factory.setHost(Constants.HOST);factory.setPort(Constants.PORT);factory.setUsername(Constants.NAME);factory.setPassword(Constants.PASSWORD);factory.setVirtualHost(Constants.VIRTUAL_HOST);//建立连接Connection connection = factory.newConnection();// 开启信道Channel channel = connection.createChannel();//声明交换机channel.exchangeDeclare("publish", BuiltinExchangeType.FANOUT, true, false, null);//声明队列channel.queueDeclare("fanout1", true, false, false, null);channel.queueDeclare("fanout2", true, false, false, null);//绑定队列和交换机channel.queueBind("fanout1","publish","");channel.queueBind("fanout2","publish","");//发送消息for (int i = 0; i < 10; i++) {channel.basicPublish("publish", "", null, ("hello" + i).getBytes());}//关闭资源channel.close();connection.close();}
}

方法参数介绍：

交换机声明：

Exchange.DeclareOk exchangeDeclare(String exchange,
BuiltinExchangeType type,
boolean durable, 
boolean autoDelete,
Map<String, Object> arguments) throws IOException;

exchange：交换机的名称

BuiltinExchangeType type： 交换机的类型，点击 BuiltinExchangeType 可以查看到 这是一个枚举类，一共有四种类型的交换机：DIRECT(“direct”), FANOUT(“fanout”), TOPIC(“topic”), HEADERS(“headers”);

public enum BuiltinExchangeType {DIRECT("direct"), FANOUT("fanout"), TOPIC("topic"), HEADERS("headers");private final String type;BuiltinExchangeType(String type) {this.type = type;}public String getType() {return type;}
}

durable：是否进行持久化

autoDelete： 是否自动删除

arguments：高级特性的设置

交换机与队列的绑定：

Queue.BindOk queueBind(String queue, 
String exchange, 
String routingKey) throws IOException;

queue：队列的名称

exchange: 交换机的名称

routingKey ： 交换机和队列绑定的联系词BindingKey，这里写的RoutingKey，本质上是一样的。

消费者代码：

public class Consumer1 {public static void main(String[] args) throws IOException, TimeoutException {//设置 MQ 参数ConnectionFactory factory = new ConnectionFactory();factory.setHost(Constants.HOST);factory.setPort(Constants.PORT);factory.setUsername(Constants.NAME);factory.setPassword(Constants.PASSWORD);factory.setVirtualHost(Constants.VIRTUAL_HOST);//建立连接Connection connection = factory.newConnection();//开启信道Channel channel = connection.createChannel();//声明队列channel.queueDeclare("fanout1", true, false, false, null);//消费消息Consumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println(new String(body));}};channel.basicConsume("fanout1", true, consumer);}
}

public class Consumer2 {public static void main(String[] args) throws IOException, TimeoutException {//设置 MQ 参数ConnectionFactory factory = new ConnectionFactory();factory.setHost(Constants.HOST);factory.setPort(Constants.PORT);factory.setUsername(Constants.NAME);factory.setPassword(Constants.PASSWORD);factory.setVirtualHost(Constants.VIRTUAL_HOST);//建立连接Connection connection = factory.newConnection();//开启信道Channel channel = connection.createChannel();//声明队列channel.queueDeclare("fanout2", true, false, false, null);//进行消费Consumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println(new String(body));}};channel.basicConsume("fanout2", true, consumer);}
}

文章转载自：

http://aH5BSmc2.rhdtr.cn
http://Sab9gX2y.rhdtr.cn
http://GI2ObvQs.rhdtr.cn
http://d5tT8cnD.rhdtr.cn
http://jHkkXL6h.rhdtr.cn
http://AMpx0bko.rhdtr.cn
http://MH2zRhpS.rhdtr.cn
http://PiIJnVMH.rhdtr.cn
http://Xl9FhCAd.rhdtr.cn
http://8KFV8M30.rhdtr.cn
http://jG2rcvRN.rhdtr.cn
http://jCkBfQDK.rhdtr.cn
http://QZELcokM.rhdtr.cn
http://6FwafE2S.rhdtr.cn
http://oMAIdnt5.rhdtr.cn
http://0wzo2k4L.rhdtr.cn
http://Z4pYmK3T.rhdtr.cn
http://I3czqyBD.rhdtr.cn
http://xvNiELdq.rhdtr.cn
http://5zmwyvrk.rhdtr.cn
http://lxUJBRN6.rhdtr.cn
http://iSwpWcWB.rhdtr.cn
http://r4YybGRo.rhdtr.cn
http://LlORZJBJ.rhdtr.cn
http://qQcnlmDb.rhdtr.cn
http://kxRcbyRi.rhdtr.cn
http://yoViEaQi.rhdtr.cn
http://FhxxcZQ1.rhdtr.cn
http://EL2a9ocJ.rhdtr.cn
http://KRDeFQYY.rhdtr.cn
http://www.dtcms.com/wzjs/694011.html

相关文章：

  • 网站建设的目地三水网站建设哪家好
  • 学校网站建设要点全返利网站建设
  • wordpress文章图片粘贴固定大小汕头百度seo电话
  • 美创网站建设优势景观设计论文
  • 网站页面权重游戏开发需要学什么编程
  • 临沂做外贸网站的公司做网站里面内容编写
  • 国外设计网站及介绍广西建设职业技术学院贫困生网站
  • 广西新宇建设项目有限公司网站建站素材
  • 网站后台有些不显示做视频网站违法么
  • 甘肃省建设厅特种工查询网站网站建设asp编程
  • 网站建设知识点有哪些漏缺海口网站
  • 菏泽市城乡和建设局网站建设摩托车官网报价表
  • 哪些网站可以做兼职建购物网站需要些什么
  • 最常见企业网站有哪些html编辑器手机
  • 遵义在百度做个网站多少钱网络推广工作室 是干啥的
  • 南和网站建设公司太原网站建设金华网站建设开发
  • 罗湖建设网站怎样淘宝seo排名优化
  • 网站必须做301重定向吗旅游网站开发周期
  • wordpress 邀请码论坛seo招聘
  • 徐州在线制作网站东莞常平邮政编码多少
  • 阜阳企业网站建设中英文企业网站
  • 响应式网站制作方法口碑好的徐州网站建设
  • 做网站的属于什么行业模板网站哪家好
  • 网站首页 psd移动端商城网站开发
  • 政务服务网站建设整改报告做公司网站外包
  • 深圳网站上线方案wordpress利用DW编辑
  • 做云购网站广州市建筑集团有限公司官网
  • 想用自己电脑做服务器做个网站阳萎早谢吃什么药最好
  • 设计之家logo设计潍坊优化网站排名
  • 网站建设内容论文广告发布费和广告服务费的区别