f45gpqkY1FKu
下载Nginx源码 手动下载并上传到服务器 nginxnews 源码下载链接http://nginx.org/download/nginx-1.18.0.tar.gz 服务器直接下载 $:cdtemp $:wgethttp://nginx.org/download/nginx-1.18.0.tar.gz 编译并安装 解压nginx源码包 $:tar-xvzfnginx-1.18.0.tar.gz 生成Makefile 文档：BuildingnginxfromSources $:cdnginx-1.18.0 默认直接./configure不需要跟后面的参数，如果需要修改配置在后面...
镜像队列 队列创建只在创建的机器上出现，不会出现在其他节点上，需要创建镜像队列，将队列备份到其他节点，可以备份到其他节点或者全部节点 创建：在任意一个节点上添加一个policy即可 在Web管理界面设置：admin->policies->Add/updateapolicy-> Name:mirror-two Pattern:^mirror备份以mirror开头的队列 Definition:ha-mode->exactly ha-params->2 ha-sync-mode->automactic HaProxy实现负载均衡+keepalive=高可用 H...
单机性能差，搭建多台机器可以提高性能 机器名称：Node1、Node2、Node3，Node1为主节点，其他机器与Node1建立连接，其他Node4等机器也可以连接到Node2/Node3 IP地址： node1:166.166.166.92 node2:166.166.166.93 node3:166.166.166.94 修改主机名称： $:sudovim/etc/hostname 配置各个节点的hosts文件： /etv/hosts 166.166.166.92node1 166.166.166.93node2 166.166.166.94node3 确保各个节点的cooki...
幂等性 用户对于同一操作发起的一次请求或多次请求的结果是不一致的，不会因为多次点击而产生了副作用。 消息被重复消费 解决思路：一般使用全局ID或者时间戳、UUID，判断此ID是否已经被消费过 唯一ID+指纹码 Redis原子性：天然自带幂等性 优先级队列 订单催付：按客户大小判断是否优先处理 0-255：越大越优先 //队列代码中添加 valarguments=mapof("x-max-priority"to10) //消息代码中添加 valproperties=AMQP.BasicProperties().builder().prioriry(5).build() 注意：队列需要先设...
RabbitMQ服务器因不明原因重启，导致生产者消息投递失败，如何进行可靠投递？ 生产者发消息到交换机，交换机/队列不存在或者无法接受消息，要对缓存进行处理 对发送的消息进行备份，用定时任务对未成功的消息进行重新投递 1）SpringBoot版本 配置文件：application.properties spring.rabbitmq.publisher-confirm-type=correlated 添加配置类 importorg.springframework.amqp.core.Binding importorg.springframework.amqp.core.BindingBu...
死信：无法被消费的消息 死信队列：当消息消费发生异常，将消息投入死信队列，防止消息丢失。比如：用户在商城下单成功在指定时间未支付时自动失效 死信来源：消息TTL过期、队列达到最大长度、消息被拒（否定应答或拒绝应答，不自动放回队列，等后续有空再来处理） 消息TTL过期 //生产者 importcn.soldat.utils.RabbitMqUtils importcom.rabbitmq.client.AMQP objectProducer{ constvalNORMAL_EXCHANGE="normal_exchange"//普通交换机名称 } funmain(){ valchannel...
生产者发消息到队列，设置要求队列必须持久化、设置要求队列中的消息必须持久化 存在传送到队列中必须保存到磁盘上才能实现持久化，但是在保存之前已经宕机，无法实现持久化； 此时必须增加发布确认（保存到磁盘后进行确认）才能保证确实保存在磁盘上 开启发布确认方法 //信道开启发布确认 channel.confirmSelect() 有三种方式： 单独发布消息：同步等待确认，简单，吞吐量非常有限，发布速度特别慢 批量确认消息：合理吞吐量，一旦出现问题，不知道是哪个消息出了问题 异步确认消息：（推荐使用）代码复杂，速度快，不会丢失消息，性价比高 /单个确认发布1000个单独确认消息，耗时：300ms/...
RoutingKey必须时一个单词列表，已点号分隔开，比其他交换机更完美（info.base.xxx），最长不能超过255个字节 注意：可以代替一个单词；可以替代零个或多个单词，不匹配的任何绑定会被丢弃； 当一个队列RoutingKey是，那么这个队列将接收所有数据，有点像fanout 如果队列RoutingKey中没有或，那么这个队列类型就是direct //生产者 importcn.soldat.utils.RabbitMqUtils objectEmitLogTopic{ //交换机名称 constvalEXCHANGE_NAME="t...
交换机绑定的RoutingKey不同，只给某个队列发消息 多重绑定：绑定同一个队列的RoutingKey不同 //生产者 importcn.soldat.utils.RabbitMqUtils importcom.rabbitmq.client.BuiltinExchangeType importjava.util. objectDirectLogs{ constvalEXCHANGE_NAME="direct_logs" } funmain(){ valchannel=RabbitMqUtils.getChannel() channel.exchangeDeclare(DirectLo...
避免立即执行资源密集型任务,生产者大量发消息到队列中，单个消费者线程无法及时处理，多个消费者线程轮询处理消息 注意：一个消息只能被处理一次，不可以被处理多次 提取公共代码：RabbitMQUtils objectRabbitMQUtils{ fungetChannel():Channel{ //创建连接工厂 valfactory=ConnectionFactory() factory.host="166.166.166.92" factory.username="admin" factory.password="123456" //创建连接 valconnection=factory.ne...
HelloWorld（简单模式） 开发配置：kotlin1.6.20+gradle7.4.1 plugins{ id'org.jetbrains.kotlin.jvm'version'1.6.20' } group'cn.soldat' version'1.0' repositories{ maven{ url'https://maven.aliyun.com/repository/public/' } mavenLocal() mavenCentral() } dependencies{ implementation"org.jetbrains.kotlin:kotlin-stdli...
1）安装虚拟机 环境：Mac+ParallesDesktop16+Debian10Arm64 IP地址：166.166.166.92 配置源： debhttps://mirror.sjtu.edu.cn/debian/bullseyemaincontribnon-free deb-srchttps://mirror.sjtu.edu.cn/debian/bullseyemaincontribnon-free debhttps://mirror.sjtu.edu.cn/debian/bullseye-updatesmaincontribnon-free deb-srchttps://mirr...