首页
学习
活动
专区
工具
TVP
发布

个人技术栈

专栏成员
11
文章
30077
阅读量
14
订阅数
死信队列
/** * @Auther: Administrator * @Date: 2019年7月16日 * @Description: 死信交换机 生产者首先发送一条携带路由键为 " dlx " 的消息,然后经过交换器 * exchange .normal 顺利地存储到队列 queue.normal 中 。由于队列 queue.normal 设置了过期时间为 * 10s , 在这 10s 内没有消费者消费这条消息,那么判定这条消息为过期。由于设置了 DLX , 过期 * 之时 , 消息被丢给交换
清风冷影
2019-07-16
4440
Rabbit 过期时间 (TTL)
TTL, Time to Live 的简称,即过期时间 。 RabbitMQ 可以对消息和队列设置 TTL 。 设置消息的 TTL 目前有两种方法可以设置消息的 TTL。第一种方法是通过队列属性设置,队列中所有消息 都有相同的过期时间。第二种方法是对消息本身进行单独设置,每条消息的 TTL 可以不同。 如果两种方法同时使用,则消息的 TTL以两者之间较小的那个数值为准。消息在队列中的生存时间一旦超过设置 的 TTL 值时, 就会变成"死信" (Dead Message) ,消费者将无法再收到该消息 (不是绝
清风冷影
2019-07-16
1.6K0
rabbitmq channel参数详解
Channel channel.exchangeDeclare(): type:有direct、fanout、topic三种 durable:true、false true:服务器重启会保留下来Exchange。警告:仅设置此选项,不代表消息持久化。 即不保证重启后消息还在。原文:true if we are declaring a durable exchange (the exchange will survive a server restart) autoDelete:true、false.tru
清风冷影
2019-07-15
1.6K0
连接 RabbitMQ
下面的代码(代码清单子 1 )用来在给定的参数(lp 地址、端口号、用户名、密码等)下 连接 RabbitMQ: public static Connection getConnection() throws IOException, TimeoutException{ //定义一个连接工厂 ConnectionFactory factory =new ConnectionFactory(); //设置服务地址 factory.setHost(IP_ADDRESS); /
清风冷影
2019-07-12
7210
RabbitMQ的生产者和消费者
图 2-2 展示 了 生产者将消息存入 RabbitMQ Broker,以及消费者从 Broker 中消费数据的整 个流程。
清风冷影
2019-07-11
3.7K0
显式Mapping设置与常见参数介绍
就是说:Cannot search on field [mobile] since it is not indexed mobile 没有被索引 所以不能进行搜索
清风冷影
2019-07-10
1.7K0
Query String & Simple Query String
1、向搜索库中添加数据 PUT /users/_doc/1 { "name":"Ruan Yiming", "about":"java, golang, node, swift, elasticsearch" } PUT /users/_doc/2 { "name":"Li Yiming", "about":"Hadoop" } 2、使用query_string 查询数据 POST users/_search { "query": { "query_string": {
清风冷影
2019-07-10
1.3K0
Incorrect column count: expected 1, actual 2
错误代码 使用JdbcTemplate查询 String sql="SELECT t.industry_code AS item, COUNT (1) AS intValue FROM company_info t GROUP BY industry_code"; List<LineChartShowBean> pollutionCityBeans = trJdbcTemplate.queryForList(sql, LineChartShowBean.class); que
清风冷影
2019-07-03
3.2K0
springboot使用@RabbitListener注解消费消息
@RabbitListener注解指定目标方法来作为消费消息的方法,通过注解参数指定所监听的队列或者Binding。
清风冷影
2019-07-02
12.8K0
Access denied for user ''@'localhost' (using password: NO)
正确的配置文件 spring: data: elasticsearch: cluster-nodes: 192.168.0.105:9300 datasource:
清风冷影
2019-07-01
2.4K0
elasticsearch使用笔记(整合SpringBoot)(1)
@Document 源码详解 @Persistent @Inherited @Retention(RetentionPolicy.RUNTIME) @Target({ElementType.TYPE}) public @interface Document { String indexName(); //索引库的名称 String type() default ""; //文档的类型 一般以实体的类型命名 boolean useServerConfiguration() defaul
清风冷影
2019-06-21
5890
没有更多了
社区活动
【纪录片】中国数据库前世今生
穿越半个世纪,探寻中国数据库50年的发展历程
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档