# apollo 单机部署 (快速安装) Apollo 官网：https://www.apolloconfig.com/#/zh/deployment/quick-start-docker 官网单机部署的方式分为两种：普通部署和 docker 部署。 # 1、普通部署 需要安装 MySQL 和 Java 环境。 Apollo 服务端共需要两个数据库： ApolloPortalDB (apollo 页面) 和 ApolloConfigDB (apollo 使用的)，把数据库、表的创建和样例数据都分别准备了 sql 文件，只需要导入数据库即可。 ps:数据库Mysql的版本建议在5.7以上，...

# 科学上网 # 1、准备工作 首先你得先下载 xshell，xshell 官网提供个人免费版下载，直接去 官网下载 即可。 然后你得需要一个国外的服务器，这里使用的是 vultr 的服务器。 # 2、注册购买 vultr 服务器 具体操作步骤略过，不会的话查询百度吧。 ps:购买了服务器后简易先本地ping一下，如果延迟太大可以销毁重购 # 3、运行 xshell 连接上刚买的国外服务器 接下来就是执行一系列的脚本，现在是简易版，没有过多解释，直接照做就行。 # 1. 安装 ssr 用 xshell 连上服务器后，执行以下命令 wget --no-check-certificate...

看图 # 1、访问你的 kafka-manager 首页 你会看到这样一个页面，当然你的 Clusters 可能是空的 # 2、我们新增一个集群 按照图中勾选的勾上，其他默认就行 主要说明一下 kafka 版本需要你自己去找，或者默认就行。然后 Zookeeper 集群的 Host 是 ip:port 的形式，多个服务之间用逗号分隔。 # 3、查看结果 以上为新增的一些操作，其他的功能以后再添加！

近期想学习一下 Kafka，所以打算在自己的服务器上搭建一个 Kafka 集群供以后自己使用，查阅了资料之后发现可以使用 Docker 搭建，简单快捷，以下整合记录了整个集群的搭建过程。 # 一、搭建 Zookeeper 集群环境 # 1、拉取 zookeeper 镜像 docker pull zookeeperdocker tag docker.io/zookeeper zookeeperdocker rmi docker.io/zookeeper# 2、安装 docker-compose 工具 ps：如果已经安装可以跳过这一步 # 升级 pippip3 install --upgrade...

最近遇见了一个好玩的事。我一朋友在同一台服务器上配了安装了多套服务。一套 java 的项目，还有一套 apollo 的管理程序。想要通过多个二级域名的方式进行解析。下面就以配置 apollo 的域名解析为例做个简单记录。 # 0、前提 已知，我们现在有一个域名 yuming.cn, 另外，apollo 项目通过 docker 的方式部署在服务器上，通过 ip:8070 可以访问 # 1、域名解析 首先，要有个域名，如果是国内的服务器还要做好备案。然后在域名管理页面做好域名解析。这里我们想通过 apollo.host.cn 进行访问 # 2、安装...

作为 rabbitMQ 的生产者，发送消息到 MQ 的过程中，是通过 routingkey 发送给交换机，由交换机进行路由，把信息发送的最终的队列中。而 rabbitMQ 消费的时候，是要明确指明消费的队列的。 # 消费模式 rabbitMQ 的消费模式分为两种，推模式和拉模式。推模式使用的是 Basic.Consume 进行消费，而拉模式通过调用 Basic.Get 进行消费。推模式用于持续的获取消息，在推模式中，RabbitMQ 会不断的推送消息给消费者，不过推送的数量可以通过 Basic.Qos 进行限制。拉模式可以单条的获取信息。 #...

# 过期时间 RabbitMQ 有两种方式可以设置消息的过期时间。第一种是通过队列属性设置，队列中所有的信息都有相同的过期时间，第二种方式是对消息本身进行单独设置，每条消息的 TTL 可以不同。** 如果两种方式一起中，则消息的 TTL 以两者之间较短的那个数值为准。** 消息在队列中的生存时间，一旦超过设置的 TTL 时，就会变成 “死信”。 # springboot 中设置消息 TTL 的方式 # 设置队列属性 @Bean public Queue ttlQueue() { Map<String, Object> param = new...

# Springboot 集成 rabbitmq 之 mandatory 和备份交换机 # mandatory 之前编写的消息队列代码中，通过重写 ConfirmCallback 中的 confirm 方法实现了消息送达的确认以及出错的处理，但是，该方法无法判断消息投递到不存在的队列中导致失败的问题。 mandatory 是 channel.basicPublish 方法中的参数，当 mandatory 设置为 true 时，交换机无法根据自身的类型和路由键找到一个符合条件的队列，那么就会调用 Basic.Return 命令将消息返回给生产者。当 mandatory 参数设置为 false...

# springboot 集成 rabbitMQ2 上篇文章，用 springboot 的默认配置，完成了 rabbitMQ 消息的发送，但是缺点也很明显，就是需要事先在管理页面创建好对应的 Exchange 和 Queue 以及 Binding 关系。但是其实 rabbitMQ 可以在发送的时候进行检查，如不存在，则创建。这个就需要结合 @Configration 和 @ @Bean 进行配置 # rabbitMQ 自定义配置 # 通过 config 文件进行配置 依然按照之前的配置，使用 topic 交换机，交换机名字叫做 config_exchange，并且使用名叫 test.topic...

# springboot 集成 RabbitMQ -1 # RabbitMQTemplate 在 springboot 中，用的比较多是 rabbitMQTemplate。通过 rabbitMQTemplate 结合 spring 的 bean 管理，可以比较方便的进行开发。 # 1、导入依赖 <dependency> <groupId>org.springframework.boot</groupId>...