SpringBoot 的支持 SpringBoot 已经提供了对 AMQP 协议完全支持的 spring-boot-starter-amqp 依赖，引入此依赖即可快速方便的在 SpringBoot 中使用 RabbitMQ。参考：Spring AMQP。 特点 用于异步处理消费消息的监听器容器。 用于发送和接收消息的 RabbitTemplate。 RabbitAdmin 用于自动声明队列、交换和绑定。 RabbitAdmin 作用 declareExchange：创建交换机。 deleteExchange：删除交…
简单使用 创建一个 SpringBoot 项目即可直接使用 Logback 进行日志打印，只需引入 spring-boot-starter-web： 在依赖 spring-boot-starter-logging 都已经引用好了，随后直接启动项目： 这里仅仅只是创建了一个 SpringBoot 项目，什么都没有配置，启动之后，日志也已经存在了。仔细观察可以看出打印的日志是具有同一格式的，依次是日期、时间、日志级别、进程号（PID）、线程名、包路径、具体日志消息。 至于为什么默认实现是 Logback，有…
死信队列的作用 使用 RabbitMQ 的时候可能会碰到以下几个问题： 消费者端调用了 basicNack 或者 basicReject，并且没有进行 requeue，如果没做其他措施的话，这个消息也就丢失了。 消息在队列的存活时间超过设置的 TTL 时间。 消息队列的消息数量已经超过最大队列长度。 以上几个问题都会导致消息丢失，消息丢失的代价可大可小，视自己业务情况而定，有些业务如果消息丢失无所谓的话就不用理睬，相信大部分业务都是不允许丢失的。死信队列的出现就可以解决以上三个问题，当以上三个问题出现时，消…
软件版本 软件 版本 Spring Boot 2.5.0 spring-boot-starter-amqp 2.5.0 Erlang 24.0 RabbitMQ 3.8.19 发送消息 配置信息 spring: rabbitmq: host: localhost port: 5672 username: admin password: 123456 virtual-host: 'example' # 生产者 ==>> Exchange 确认方式 publisher-confirm-type: corre…
Maven 依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-elasticsearch</artifactId> </dependency> ElasticsearchRepository<T, ID> Spring 提供的便捷操作 Dao 层接口，通过继承此接口可以实现简单的增删改查操作。 T…
说明 环境 工具 版本 SpringBoot 2.3.3 Docker 19.03.12 Kubernetes 1.14 背景 服务端要支持 N 多个 Tcp Client 连接，所以做了负载，Tcp Client 会根据负载策略连接到不同的后端 Pod 上，这样就需要维护一个路由表：内部 ip <<==>> Tcp Client 的映射关系。所以在项目关闭的时候要有个关闭前处理（把当前 Pod 路由从路由表中去掉）的过程，也就是优雅关闭①。 SpringBoot 优雅关闭 配置 ser…
官方说：For servlet stack applications, the spring-boot-starter-web includes Tomcat by including spring-boot-starter-tomcat, but you can use spring-boot-starter-jetty or spring-boot-starter-undertow instead When switching to a different HTTP server, you need t…
这几天在写一个团队使用的工具，有一些东西呢，需要从 Spring Cloud 配置中心中读取配置信息进行加载初始化，所以做了一个 Starter 。 pom 依赖 <properties> <!-- Spring Boot --> <spring.boot>1.5.9.RELEASE</spring.boot> </properties> <dependencyManagement> <dependencies> <dep…
此篇笔记是以上篇笔记为基础：Spring Boot 结合 Redis Cluster RedisTemplate 关于 Redis Cache Manager 的微小修改 import org.springframework.cache.CacheManager; import org.springframework.cache.annotation.EnableCaching; import org.springframework.cache.interceptor.KeyGenerator; import or…
Redis Cluster 搭建：Redis Cluster 从零安装并详解 此篇笔记以上放这篇笔记为基础 pom 依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> yml 配置 spring: redis: cluster: # 各…