《Rabbitmq》学习

你的名字 2022-10-10 01:41 147阅读 0赞

### 文章目录 ###

*   *  概述
     *  优势
     *  劣势
     *  安装及启动使用
     *  MQ整合SpringBoot
     *  六种工作模式
     *  Helloworld模式
     *  Work queues工作模式
     *  Pub/Sub订阅模式
     *  Routing路由模式
     *  Topics 通配符模式

## 概述 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 3]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 4]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 5]

## 优势 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 6]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 7]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 8]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 9]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 10]

## 劣势 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 11]

## 安装及启动使用 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 12]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 13]  
端口15672  
默认账号密码为guest  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 14]  
新增虚拟机  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 15]  
新增管理员用户  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 16]  
绑定用户  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 17]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 18]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 19]

## MQ整合SpringBoot ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 20]

<dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 21]

server.port=8080
    #这几个是默认配置。 不配也行。
    #spring.rabbitmq.host=localhost
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest
    spring.rabbitmq.addresses=42.192.145.166
    spring.rabbitmq.virtual-host=/
    
    
    #spring.rabbitmq.addresses=172.16.48.10:5672,172.16.48.11:5672,172.16.48.12:5672

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 22]  
ProducerController

import io.swagger.annotations.ApiOperation;
    import org.springframework.amqp.AmqpException;
    import org.springframework.amqp.core.Message;
    import org.springframework.amqp.core.MessageProperties;
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.io.UnsupportedEncodingException;
    
    @RestController
    public class ProducerController { 
    
    	@Autowired
    	private RabbitTemplate rabbitTemplate;
    	
    	//helloWorld 直连模式
    	@ApiOperation(value="helloWorld发送接口",notes="直接发送到队列")
    	@GetMapping(value="/helloWorldSend")
    	public Object helloWorldSend(String message) throws AmqpException, UnsupportedEncodingException { 
    		//设置部分请求参数
    		MessageProperties messageProperties = new MessageProperties();
    		messageProperties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
    
    		//发消息
    		rabbitTemplate.send("helloWorldqueue",new Message(message.getBytes("UTF-8"),messageProperties));
    		return "message sended : "+message;
    	}
    
    
    	//工作队列模式
    	@ApiOperation(value="workqueue发送接口",notes="发送到所有监听该队列的消费")
    	@GetMapping(value="/workqueueSend")
    	public Object workqueueSend(String message) throws AmqpException, UnsupportedEncodingException { 
    		MessageProperties messageProperties = new MessageProperties();
    		messageProperties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
    		//制造多个消息进行发送操作
    		for (int i = 0; i <10 ; i++) { 
    			rabbitTemplate.send("work_sb_mq_q",  new Message(message.getBytes("UTF-8"),messageProperties));
    		}
    		return "message sended : "+message;
    	}
    
    
    	// pub/sub 发布订阅模式   交换机类型 fanout
    	@ApiOperation(value="fanout发送接口",notes="发送到fanoutExchange。消息将往该exchange下的所有queue转发")
    	@GetMapping(value="/fanoutSend")
    	public Object fanoutSend(String message) throws AmqpException, UnsupportedEncodingException { 
    		MessageProperties messageProperties = new MessageProperties();
    		messageProperties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
    		//fanout模式只往exchange里发送消息。分发到exchange下的所有queue
    		rabbitTemplate.send("fanoutExchange", "", new Message(message.getBytes("UTF-8"),messageProperties));
    		return "message sended : "+message;
    	}
    
    
    	//routing路由工作模式  交换机类型 direct
    	@ApiOperation(value="direct发送接口",notes="发送到directExchange。exchange转发消息时，会往routingKey匹配的queue发送")
    	@GetMapping(value="/directSend")
    	public Object routingSend(String routingKey,String message) throws AmqpException, UnsupportedEncodingException { 
    
    		if(null == routingKey) { 
    			routingKey="china.changsha";
    		}
    		MessageProperties messageProperties = new MessageProperties();
    		messageProperties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
    		//fanout模式只往exchange里发送消息。分发到exchange下的所有queue
    		rabbitTemplate.send("directExchange", routingKey, new Message(message.getBytes("UTF-8"),messageProperties));
    		return "message sended : routingKey >"+routingKey+";message > "+message;
    	}
    
    
    	//topic 工作模式   交换机类型 topic
    	@ApiOperation(value="topic发送接口",notes="发送到topicExchange。exchange转发消息时，会往routingKey匹配的queue发送，*代表一个单词，#代表0个或多个单词。")
    	@GetMapping(value="/topicSend")
    	public Object topicSend(String routingKey,String message) throws AmqpException, UnsupportedEncodingException { 
    
    		if(null == routingKey) { 
    			routingKey="changsha.kf";
    		}
    		MessageProperties messageProperties = new MessageProperties();
    		messageProperties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
    		//fanout模式只往exchange里发送消息。分发到exchange下的所有queue
    		rabbitTemplate.send("topicExchange", routingKey, new Message(message.getBytes("UTF-8"),messageProperties));
    		return "message sended : routingKey >"+routingKey+";message > "+message;
    	}
    
    }

ConcumerReceiver

import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
    import org.springframework.amqp.rabbit.connection.ConnectionFactory;
    import org.springframework.context.annotation.Bean;
    import org.springframework.stereotype.Component;
    
    @Component
    public class ConcumerReceiver { 
    	
    
    	
    	//直连模式的多个消费者，会分到其中一个消费者进行消费。类似task模式
    	//通过注入RabbitContainerFactory对象，来设置一些属性，相当于task里的channel.basicQos
    	@RabbitListener(queues="helloWorldqueue")
    	public void helloWorldReceive(String message) { 
    
    	     System.out.println("helloWorld模式 received message : " +message);
    	}
    
    	//工作队列模式
        @RabbitListener(queues="work_sb_mq_q")
        public void wordQueueReceiveq1(String message) { 
    
    		System.out.println("工作队列模式1 received message : " +message);
        }
    
        @RabbitListener(queues="work_sb_mq_q")
        public void wordQueueReceiveq2(String message) { 
    
    		System.out.println("工作队列模式2 received message : " +message);
        }
    
    
    	//pub/sub模式进行消息监听
    	@RabbitListener(queues="fanout.q1")
    	public void fanoutReceiveq1(String message) { 
    
    	    System.out.println("发布订阅模式1received message : " +message);
    	}
    	@RabbitListener(queues="fanout.q2")
    	public void fanoutReceiveq2(String message) { 
    
    	    System.out.println("发布订阅模式2 received message : " +message);
    	}
    
    
        //Routing路由模式
        @RabbitListener(queues="direct_sb_mq_q1")
        public void routingReceiveq1(String message) { 
    
    	    System.out.println("Routing路由模式routingReceiveq11111 received message : " +message);
        }
    
        @RabbitListener(queues="direct_sb_mq_q2")
        public void routingReceiveq2(String message) { 
    
    	    System.out.println("Routing路由模式routingReceiveq22222 received message : " +message);
        }
    
    
        //topic 模式
    	//注意这个模式会有优先匹配原则。例如发送routingKey=hunan.IT,那匹配到hunan.*(hunan.IT,hunan.eco),之后就不会再去匹配*.ITd
    	@RabbitListener(queues="topic_sb_mq_q1")
    	public void topicReceiveq1(String message) { 
    		System.out.println("Topic模式 topic_sb_mq_q1 received message : " +message);
    	}
    
    	@RabbitListener(queues="topic_sb_mq_q2")
    	public void topicReceiveq2(String message) { 
    		System.out.println("Topic模式 topic_sb_mq_q2 received message : " +message);
    	}
    
    
    
    	
    }

--------------------

HelloWorldConfig

import org.springframework.amqp.core.Queue;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    /**
     * HelloWorld rabbitmq课上讲解的第一个工作模式
     * 直连模式只需要声明队列，所有消息都通过队列转发。
     * 无需设置交换机
     */
    @Configuration
    public class HelloWorldConfig { 
    
    	@Bean
    	public Queue setQueue() { 
    		return new Queue("helloWorldqueue");
    	}
    }

WorkConfig

import org.springframework.amqp.core.Queue;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class WorkConfig { 
    
    
        //声明队列
        @Bean
        public Queue workQ1() { 
            return new Queue("work_sb_mq_q");
        }
    
    }

FanoutConfig

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;
    
    /**
     * Fanout模式需要声明exchange，并绑定queue，由exchange负责转发到queue上。
     * 广播模式 交换机类型设置为：fanout
     */
    @Configuration
    public class FanoutConfig { 
    
    	//声明队列
    	@Bean
    	public Queue fanoutQ1() { 
    		return new Queue("fanout.q1");
    	}
    	@Bean
    	public Queue fanoutQ2() { 
    		return new Queue("fanout.q2");
    	}
    
    
    	//声明exchange
    	@Bean
    	public FanoutExchange setFanoutExchange() { 
    		return new FanoutExchange("fanoutExchange");
    	}
    
    
    	//声明Binding,exchange与queue的绑定关系
    	@Bean
    	public Binding bindQ1() { 
    		return BindingBuilder.bind(fanoutQ1()).to(setFanoutExchange());
    	}
    	@Bean
    	public Binding bindQ2() { 
    		return BindingBuilder.bind(fanoutQ2()).to(setFanoutExchange());
    	}
    
    }

DirectConfig

import org.springframework.amqp.core.*;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    
    /*
       路由模式|Routing模式   交换机类型：direct
    */
    @Configuration
    public class DirectConfig { 
    
    	//声明队列
    	@Bean
    	public Queue directQ1() { 
    		return new Queue("direct_sb_mq_q1");
    	}
    	@Bean
    	public Queue directQ2() { 
    		return new Queue("direct_sb_mq_q2");
    	}
    
    
    	//声明exchange
    	@Bean
    	public DirectExchange setDirectExchange() { 
    		return new DirectExchange("directExchange");
    	}
    
    	//声明binding，需要声明一个routingKey
    	@Bean
    	public Binding bindDirectBind1() { 
    		return BindingBuilder.bind(directQ1()).to(setDirectExchange()).with("china.changsha");
    	}
    	@Bean
    	public Binding bindDirectBind2() { 
    			return BindingBuilder.bind(directQ2()).to(setDirectExchange()).with("china.beijing");
    	}
    
    }

TopicConfig

import org.springframework.amqp.core.Binding;
    import org.springframework.amqp.core.BindingBuilder;
    import org.springframework.amqp.core.Queue;
    import org.springframework.amqp.core.TopicExchange;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    
    /*
    Topics模式  交换机类型 topic
    * */
    @Configuration
    public class TopicConfig { 
    
    	//声明队列
    	@Bean
    	public Queue topicQ1() { 
    		return new Queue("topic_sb_mq_q1");
    	}
    	@Bean
    	public Queue topicQ2() { 
    		return new Queue("topic_sb_mq_q2");
    	}
    
    
    	//声明exchange
    	@Bean
    	public TopicExchange setTopicExchange() { 
    		return new TopicExchange("topicExchange");
    	}
    
    	//声明binding，需要声明一个roytingKey
    	@Bean
    	public Binding bindTopicHebei1() { 
    		return BindingBuilder.bind(topicQ1()).to(setTopicExchange()).with("changsha.*");
    	}
    	@Bean
    	public Binding bindTopicHebei2() { 
    		return BindingBuilder.bind(topicQ2()).to(setTopicExchange()).with("#.beijing");
    	}
    
    }

## 六种工作模式 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 23]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 24]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 25]

## Helloworld模式 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 26]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 27]

Producer

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    
    import java.io.IOException;
    import java.util.concurrent.TimeoutException;
    
    public class Producer { 
    
        public static void main(String[] args) throws IOException, TimeoutException { 
    
            ConnectionFactory connectionFactory = new ConnectionFactory();
            connectionFactory.setHost("42.192.145.166");
            connectionFactory.setPort(5672);//5672是RabbitMQ的默认端口号
            connectionFactory.setUsername("guest");
            connectionFactory.setPassword("guest");
            connectionFactory.setVirtualHost("/");
    
            //获取TCP长连接
            Connection conn = connectionFactory.newConnection();
            //创建通信“通道”，相当于TCP中的虚拟连接
            Channel channel = conn.createChannel();
    
            //创建队列,声明并创建一个队列，如果队列已存在，则使用这个队列
            //第一个参数：队列名称ID
            //第二个参数：是否持久化，false对应不持久化数据，MQ停掉数据就会丢失
            //第三个参数：是否队列私有化，false则代表所有消费者都可以访问，true代表只有第一次拥有它的消费者才能一直使用，其他消费者不让访问
            //第四个：是否自动删除,false代表连接停掉后不自动删除掉这个队列
            //其他额外的参数, null
            channel.queueDeclare(RabbitConstant.QUEUE_HELLOWORLD,false, false, false, null);
    
            String message = "hello666";
            //四个参数
            //exchange 交换机，暂时用不到，在后面进行发布订阅时才会用到
            //队列名称
            //额外的设置属性
            //最后一个参数是要传递的消息字节数组
            channel.basicPublish("", RabbitConstant.QUEUE_HELLOWORLD, null,message.getBytes());
            channel.close();
            conn.close();
            System.out.println("===发送成功===");
    
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 28]

Consumer

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.rabbitmq.client.*;
    
    import java.io.IOException;
    import java.util.concurrent.TimeoutException;
    
    public class Consumer { 
    
        public static void main(String[] args) throws IOException, TimeoutException { 
    
    
            //获取TCP长连接
             Connection conn = RabbitUtils.getConnection();
            //创建通信“通道”，相当于TCP中的虚拟连接
            Channel channel = conn.createChannel();
    
            //创建队列,声明并创建一个队列，如果队列已存在，则使用这个队列
            //第一个参数：队列名称ID
            //第二个参数：是否持久化，false对应不持久化数据，MQ停掉数据就会丢失
            //第三个参数：是否队列私有化，false则代表所有消费者都可以访问，true代表只有第一次拥有它的消费者才能一直使用，其他消费者不让访问
            //第四个：是否自动删除,false代表连接停掉后不自动删除掉这个队列
            //其他额外的参数, null
            channel.queueDeclare(RabbitConstant.QUEUE_HELLOWORLD,false, false, false, null);
    
            //从MQ服务器中获取数据
    
            //创建一个消息消费者
            //第一个参数：队列名
            //第二个参数代表是否自动确认收到消息，false代表手动编程来确认消息，这是MQ的推荐做法
            //第三个参数要传入DefaultConsumer的实现类
            channel.basicConsume(RabbitConstant.QUEUE_HELLOWORLD, false, new Reciver(channel));
    
    
        }
    }
    
    
    class  Reciver extends DefaultConsumer { 
    
        private Channel channel;
        //重写构造函数,Channel通道对象需要从外层传入，在handleDelivery中要用到
        public Reciver(Channel channel) { 
            super(channel);
            this.channel = channel;
        }
    
        @Override
        public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { 
    
             String message = new String(body);
             System.out.println("消费者接收到的消息："+message);
    
             System.out.println("消息的TagId："+envelope.getDeliveryTag());
            //false只确认签收当前的消息，设置为true的时候则代表签收该消费者所有未签收的消息
            channel.basicAck(envelope.getDeliveryTag(), false);
        }
    }

## Work queues工作模式 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 29]  
应用场景  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 30]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 31]  
OrderSystem 提供者

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.google.gson.Gson;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    
    import java.io.IOException;
    import java.util.concurrent.TimeoutException;
    
    /**
     * 发送者
     */
    public class OrderSystem { 
    
        public static void main(String[] args) throws IOException, TimeoutException { 
            Connection connection = RabbitUtils.getConnection();
            Channel channel = connection.createChannel();
            channel.queueDeclare(RabbitConstant.QUEUE_SMS, false, false, false, null);
    
            for(int i = 1 ; i <= 1000 ; i++) { 
                SMS sms = new SMS("乘客" + i, "13900000" + i, "您的车票已预订成功");
                String jsonSMS = new Gson().toJson(sms);
                channel.basicPublish("" , RabbitConstant.QUEUE_SMS , null , jsonSMS.getBytes());
            }
            System.out.println("发送数据成功");
            channel.close();
            connection.close();
        }
    }

SMSSender1 消费者

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.rabbitmq.client.*;
    
    import java.io.IOException;
    
    /**
     * 消费者
     */
    public class SMSSender1 { 
    
        public static void main(String[] args) throws IOException { 
    
    
            Connection connection = RabbitUtils.getConnection();
            final Channel channel = connection.createChannel();
    
            channel.queueDeclare(RabbitConstant.QUEUE_SMS, false, false, false, null);
    
            //如果不写basicQos（1），则自动MQ会将所有请求平均发送给所有消费者
            //basicQos,MQ不再对消费者一次发送多个请求，而是消费者处理完一个消息后（确认后），在从队列中获取一个新的
            channel.basicQos(1);//处理完一个取一个
    
            channel.basicConsume(RabbitConstant.QUEUE_SMS , false , new DefaultConsumer(channel){ 
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { 
                    String jsonSMS = new String(body);
                    System.out.println("SMSSender1-短信发送成功:" + jsonSMS);
    
                    try { 
                        Thread.sleep(10);
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    }
                    channel.basicAck(envelope.getDeliveryTag() , false);
                }
            });
        }
    
    
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 32]

## Pub/Sub订阅模式 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 33]  
应用场景  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 34]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 35]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 36]

WeatherBureau

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    
    import java.io.IOException;
    import java.util.Scanner;
    
    /**
     * 发布者
     */
    public class WeatherBureau { 
    
    
        public static void main(String[] args) throws Exception { 
    
            Connection connection = RabbitUtils.getConnection();
            String input = new Scanner(System.in).next();
            Channel channel = connection.createChannel();
    
            //第一个参数交换机名字   其他参数和之前的一样
            channel.basicPublish(RabbitConstant.EXCHANGE_WEATHER,"" , null , input.getBytes());
    
            channel.close();
            connection.close();
        }
    }

BiaDu

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.rabbitmq.client.*;
    
    import java.io.IOException;
    
    /**
     * 消费者
     */
    public class BiaDu { 
    
        public static void main(String[] args) throws IOException { 
            //获取TCP长连接
            Connection connection = RabbitUtils.getConnection();
            //获取虚拟连接
            final Channel channel = connection.createChannel();
            //声明队列信息
            channel.queueDeclare(RabbitConstant.QUEUE_BAIDU, false, false, false, null);
    
            //queueBind用于将队列与交换机绑定
            //参数1：队列名 参数2：交互机名  参数三：路由key（暂时用不到)
            channel.queueBind(RabbitConstant.QUEUE_BAIDU, RabbitConstant.EXCHANGE_WEATHER, "");
    
            channel.basicQos(1);
            channel.basicConsume(RabbitConstant.QUEUE_BAIDU , false , new DefaultConsumer(channel){ 
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { 
                    System.out.println("百度天气收到气象信息：" + new String(body));
                    channel.basicAck(envelope.getDeliveryTag() , false);
                }
            });
        }
    
    }

Sina

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.rabbitmq.client.*;
    
    import java.io.IOException;
    
    /**
     * 消费者
     */
    public class Sina { 
    
        public static void main(String[] args) throws IOException { 
            //获取TCP长连接
            Connection connection = RabbitUtils.getConnection();
            //获取虚拟连接
            final Channel channel = connection.createChannel();
            //声明队列信息
            channel.queueDeclare(RabbitConstant.QUEUE_SINA, false, false, false, null);
    
            //queueBind用于将队列与交换机绑定
            //参数1：队列名 参数2：交互机名  参数三：路由key（暂时用不到)
            channel.queueBind(RabbitConstant.QUEUE_SINA, RabbitConstant.EXCHANGE_WEATHER, "");
            channel.basicQos(1);
            channel.basicConsume(RabbitConstant.QUEUE_SINA , false , new DefaultConsumer(channel){ 
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { 
                    System.out.println("新浪天气收到气象信息：" + new String(body));
                    channel.basicAck(envelope.getDeliveryTag() , false);
                }
            });
        }
    
    }

## Routing路由模式 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 37]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 38]  
WeatherBureau

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    
    import java.util.Iterator;
    import java.util.LinkedHashMap;
    import java.util.Map;
    import java.util.Scanner;
    
    /**
     * 发布者
     */
    public class WeatherBureau { 
    
    
        public static void main(String[] args) throws Exception { 
    
            Map area = new LinkedHashMap<String, String>();
            area.put("china.hunan.changsha.20201127", "中国湖南长沙20201127天气数据");
            area.put("china.hubei.wuhan.20201127", "中国湖北武汉20201127天气数据");
            area.put("china.hunan.zhuzhou.20201127", "中国湖南株洲20201128天气数据");
            area.put("us.cal.lsj.20201127", "美国加州洛杉矶20201127天气数据");
    
            area.put("china.hebei.shijiazhuang.20201128", "中国河北石家庄20201128天气数据");
            area.put("china.hubei.wuhan.20201128", "中国湖北武汉20201128天气数据");
            area.put("china.henan.zhengzhou.20201128", "中国河南郑州20201128天气数据");
            area.put("us.cal.lsj.20201128", "美国加州洛杉矶20201128天气数据");
    
    
            Connection connection = RabbitUtils.getConnection();
            Channel channel = connection.createChannel();
    
            Iterator<Map.Entry<String, String>> itr = area.entrySet().iterator();
            while (itr.hasNext()) { 
                Map.Entry<String, String> me = itr.next();
                //第一个参数交换机名字   第二个参数作为 消息的routing key
                channel.basicPublish(RabbitConstant.EXCHANGE_WEATHER_ROUTING,me.getKey() , null , me.getValue().getBytes());
    
            }
    
            channel.close();
            connection.close();
        }
    }

BiaDu

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.rabbitmq.client.*;
    
    import java.io.IOException;
    
    /**
     * 消费者
     */
    public class BiaDu { 
    
        public static void main(String[] args) throws IOException { 
            Connection connection = RabbitUtils.getConnection();
            final Channel channel = connection.createChannel();
            channel.queueDeclare(RabbitConstant.QUEUE_BAIDU, false, false, false, null);
            //queueBind用于将队列与交换机绑定
            //参数1：队列名 参数2：交互机名  参数三：路由key
            channel.queueBind(RabbitConstant.QUEUE_BAIDU, RabbitConstant.EXCHANGE_WEATHER_ROUTING, "china.hunan.changsha.20201127");
            channel.queueBind(RabbitConstant.QUEUE_BAIDU, RabbitConstant.EXCHANGE_WEATHER_ROUTING, "china.hebei.shijiazhuang.20201128");
            channel.basicQos(1);
            channel.basicConsume(RabbitConstant.QUEUE_BAIDU , false , new DefaultConsumer(channel){ 
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { 
                    System.out.println("百度天气收到气象信息：" + new String(body));
                    channel.basicAck(envelope.getDeliveryTag() , false);
                }
            });
    
        }
    
    }

Sina

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.rabbitmq.client.*;
    
    import java.io.IOException;
    
    /**
     * 消费者
     */
    public class Sina { 
    
        public static void main(String[] args) throws IOException { 
            //获取TCP长连接
            Connection connection = RabbitUtils.getConnection();
            //获取虚拟连接
            final Channel channel = connection.createChannel();
            //声明队列信息
            channel.queueDeclare(RabbitConstant.QUEUE_SINA, false, false, false, null);
    
            //指定队列与交换机以及routing key之间的关系
            channel.queueBind(RabbitConstant.QUEUE_SINA, RabbitConstant.EXCHANGE_WEATHER_ROUTING, "us.cal.lsj.20201127");
            channel.queueBind(RabbitConstant.QUEUE_SINA, RabbitConstant.EXCHANGE_WEATHER_ROUTING, "china.hubei.wuhan.20201127");
            channel.queueBind(RabbitConstant.QUEUE_SINA, RabbitConstant.EXCHANGE_WEATHER_ROUTING, "us.cal.lsj.20201128");
            channel.queueBind(RabbitConstant.QUEUE_SINA, RabbitConstant.EXCHANGE_WEATHER_ROUTING, "china.henan.zhengzhou.20201012");
    
            channel.basicQos(1);
            channel.basicConsume(RabbitConstant.QUEUE_SINA , false , new DefaultConsumer(channel){ 
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { 
                    System.out.println("新浪天气收到气象信息：" + new String(body));
                    channel.basicAck(envelope.getDeliveryTag() , false);
                }
            });
        }
    
    }

## Topics 通配符模式 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 39]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 40]  
WeatherBureau

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    
    import java.util.Iterator;
    import java.util.LinkedHashMap;
    import java.util.Map;
    
    /**
     * 发布者
     */
    public class WeatherBureau { 
    
    
        public static void main(String[] args) throws Exception { 
    
            Map area = new LinkedHashMap<String, String>();
            area.put("china.hunan.changsha.20201127", "中国湖南长沙20201127天气数据");
            area.put("china.hubei.wuhan.20201127", "中国湖北武汉20201127天气数据");
            area.put("china.hunan.zhuzhou.20201127", "中国湖南株洲20201127天气数据");
            area.put("us.cal.lsj.20201127", "美国加州洛杉矶20201127天气数据");
    
            area.put("china.hebei.shijiazhuang.20201128", "中国河北石家庄20201128天气数据");
            area.put("china.hubei.wuhan.20201128", "中国湖北武汉20201128天气数据");
            area.put("china.henan.zhengzhou.20201128", "中国河南郑州20201128天气数据");
            area.put("us.cal.lsj.20201128", "美国加州洛杉矶20201128天气数据");
    
    
            Connection connection = RabbitUtils.getConnection();
            Channel channel = connection.createChannel();
    
            Iterator<Map.Entry<String, String>> itr = area.entrySet().iterator();
            while (itr.hasNext()) { 
                Map.Entry<String, String> me = itr.next();
                //第一个参数交换机名字   第二个参数作为 消息的routing key
                channel.basicPublish(RabbitConstant.EXCHANGE_WEATHER_TOPIC,me.getKey() , null , me.getValue().getBytes());
    
            }
    
            channel.close();
            connection.close();
        }
    }

BiaDu

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.rabbitmq.client.*;
    
    import java.io.IOException;
    
    /**
     * 消费者
     */
    public class BiaDu { 
    
        public static void main(String[] args) throws IOException { 
            Connection connection = RabbitUtils.getConnection();
            final Channel channel = connection.createChannel();
            channel.queueDeclare(RabbitConstant.QUEUE_BAIDU, false, false, false, null);
            //queueBind用于将队列与交换机绑定
            //参数1：队列名 参数2：交互机名  参数三：路由key
            channel.queueBind(RabbitConstant.QUEUE_BAIDU, RabbitConstant.EXCHANGE_WEATHER_TOPIC, "*.*.*.20201127");
           // channel.queueBind(RabbitConstant.QUEUE_BAIDU, RabbitConstant.EXCHANGE_WEATHER_ROUTING, "china.hebei.shijiazhuang.20201128");
            channel.basicQos(1);
            channel.basicConsume(RabbitConstant.QUEUE_BAIDU , false , new DefaultConsumer(channel){ 
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { 
                    System.out.println("百度天气收到气象信息：" + new String(body));
                    channel.basicAck(envelope.getDeliveryTag() , false);
                }
            });
    
        }
    
    }

Sina

import com.baiqi.rabbitmq.utils.RabbitConstant;
    import com.baiqi.rabbitmq.utils.RabbitUtils;
    import com.rabbitmq.client.*;
    
    import java.io.IOException;
    
    /**
     * 消费者
     */
    public class Sina { 
    
        public static void main(String[] args) throws IOException { 
            //获取TCP长连接
            Connection connection = RabbitUtils.getConnection();
            //获取虚拟连接
            final Channel channel = connection.createChannel();
            //声明队列信息
            channel.queueDeclare(RabbitConstant.QUEUE_SINA, false, false, false, null);
    
            //指定队列与交换机以及routing key之间的关系
            channel.queueBind(RabbitConstant.QUEUE_SINA, RabbitConstant.EXCHANGE_WEATHER_TOPIC, "us.#");
    
            channel.basicQos(1);
            channel.basicConsume(RabbitConstant.QUEUE_SINA , false , new DefaultConsumer(channel){ 
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { 
                    System.out.println("新浪天气收到气象信息：" + new String(body));
                    channel.basicAck(envelope.getDeliveryTag() , false);
                }
            });
        }
    
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70]: /images/20221005/5ec3de9401424d908defcd1b0720089e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 1]: /images/20221005/eb57ac545b94496dad31531bb3db6705.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 2]: /images/20221005/999d85ddfade481eab01096d5ecf00a9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 3]: /images/20221005/584c7e0b19b843ef8236d72da5e23f6e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 4]: /images/20221005/5d61ba6becec4f49a723674c0abab483.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 5]: /images/20221005/16409973d5c34d6fad3de5655b2ba567.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 6]: /images/20221005/535022e1aaa24e0c90f874a0fb45fd68.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 7]: /images/20221005/90b847bbc60140a3aad295e97d58ae04.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 8]: /images/20221005/6198ee2565da474f87c7f4e03c1fef5b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 9]: /images/20221005/a276a9511ec6466eadad9fa7cb18e6a4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 10]: /images/20221005/140b56f073bc40bb8f2fbb12b5cb9105.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 11]: /images/20221005/af5c627f17804bdbbc90c4f910edee43.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 12]: /images/20221005/fb73c5915a874717a660f051c39189e7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 13]: /images/20221005/97d62f782e79454087ef0984a78d998e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 14]: /images/20221005/1a601a146cf74b148090f7f4e6e85ea4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 15]: /images/20221005/4aaf439b89de48e9a0930a0891aafac4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 16]: /images/20221005/f54f7bb124da46dda9466e42a0999950.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 17]: /images/20221005/266058231f5c4d97ba735357653ed471.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 18]: /images/20221005/c4f8021f5dc34c508a09813e19ccd238.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 19]: /images/20221005/09ef0e7def494899b7da626539222734.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 20]: /images/20221005/1b9462b72b174aa3b6234193082e5cb7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 21]: /images/20221005/0c9a618518c642f8b64f4182e7ac95cd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 22]: /images/20221005/0df725c5d049408aba304fccbf39a186.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 23]: /images/20221005/a6651def4d544b5cbf0c3448cf43908f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 24]: /images/20221005/2f89b197e4d449aa8888ba6cbcb439ba.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 25]: /images/20221005/c90ab440311e4627ae44c281938a6e88.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 26]: /images/20221005/85da70aef3264e4da259b2b3810b1e02.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 27]: /images/20221005/5d9b8c63f1844f02934d1cbfb661f19a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 28]: /images/20221005/fb6b14fcd7834474a5007da2570301c1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 29]: /images/20221005/71db5c2e21e84b5e919d48acd69811d7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 30]: /images/20221005/3b2a3c0e8201455d92c84d7f70070206.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 31]: /images/20221005/823808b5dd4b42228a2e1fd35f0601fe.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 32]: /images/20221005/230f0f29e0344b2d9e66937463042255.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 33]: /images/20221005/0854af4f3d07401abbefbb28f113bc6a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 34]: /images/20221005/da2013ec40ca4c5bac14c145db7448bd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 35]: /images/20221005/c78d8cb741444ed5b15ea31f68025d1c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 36]: /images/20221005/2085d2ad5da14712a928ed3ad9a9cae0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 37]: /images/20221005/6b00c627ac5a4f16877743380d9f0c13.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 38]: /images/20221005/16f7b9d123c34069b9e2714965e94ff9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 39]: /images/20221005/3ea521e306f74c299a8a7cbdf26bc7c3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ1MjM0NTEw_size_16_color_FFFFFF_t_70 40]: /images/20221005/61bd13f58eba4734a4d51b2f67981121.png