在rabbitMQ集群中，默认发送消息时，队列默认时在一个节点上存在的。 我们以node01node02node03三节点集群为例，在node01声明队列发送消息后，发现： 测试队列只在节点node01上出现。 我们手动停止node01后，在其他节点上能看到消息，但是显示为down模式不可消费： 这就需要开启镜像队列策略： 在任意一个节点上操作： 按照添加的镜像策略重新加入一个队列： 当前的策略要求时以backup开头的交换机或者队列，这里我们测试一个backup_hello: 发现备份队列，看一下详细节点位置： 手动停止对于队列backup_hello来说的主节点n...

rabbitMQ安装插件rabbitmq-delayed-message-exchange 交换机由此type表示组件安装成功 生产者发送消息时设置延迟值消息在交换机滞纳至指定延迟后，进入队列，被消费者消费。 组件注解类： packagecom.esint.configs; importorg.springframework.amqp.core.; importorg.springframework.beans.factory.annotation.Qualifier; importorg.springframework.context.annotation.Bean; imp...

说明：生产者P往交换机X（type=direct）会发送两种消息：一、routingKey=XA的消息（消息存活周期10s），被队列QA队列绑定入列；一、routingKey=XB的消息（消息存活周期40s），被队列QB队列绑定入列。QA、QB两个队列消息在失活（变成死信消息）以routingKey=YD发送到交换机Y（type=direct）。队列QD用routingKey绑定交换机Y消息入列。消费者监听处理QD的消息。这个设计模型达到了消息从生产者到消费者延迟10s、40s不等的延迟队列处理。 这里用SpringBootmaven： <dependency> <...

【NO-1】创建一个network dockernetworkcreateapp-tier--driverbridge 【NO-2】安装zookeeper dockerrun-d--namezookeeper-server\ -p2181:2181\ --networkapp-tier\ -eALLOW_ANONYMOUS_LOGIN=yes\ bitnami/zookeeper:latest 【NO-3】installkafka （1）容器0 dockerrun-d--namekafka0\ --networkapp-tier\ -p9092:9092\ -eKAFKA_BROK...

扇出模式fanout发布订阅模式 生产者 生产者发送消息到交换机（logs）,控制台输入消息作为生产者的消息发送 packagecom.esint.rabbitmq.work03; importcom.esint.rabbitmq.RabbitMQUtils; importcom.rabbitmq.client.Channel; importjava.util.Scanner; publicclassEmitLog{ publicstaticfinalStringEXCHANGE_NAME="logs"; publicstaticvoidmain(String[]args)...

把java程序打包，发布成一个docker镜像。部署项目 1.打包我们的java程序 首选得保证本地项目是正常可运行 本地我跑了个eureka 打成eureka-0.0.1-SNAPSHOT.jar 2.编写Dockerfile文件 FROMjava:8 MAINTAINER"Phor" VOLUME/tmp ADDeureka-0.0.1-SNAPSHOT.jarappEureka.jar ENTRYPOINT["java","-jar","appEureka.jar"] 3.把jar包和Dockerfile文件上传至服务器 4.构造容器 dockerb...

IDEA开发完项目，直接部署至docker上镜像运行，接下来开始体验吧 注意：假定您的项目开发完了，假定你准备好了docker服务哈没安装docker的来抄作业（docker的安装）我的docker所在宿主机的内网ip：192.168.43.76后面需要配置出现这个地址的地方，各位大佬根据自己实际地址调整哈让你的开发及跟你的docker所在宿主机能通讯哦（防火墙什么的不要阻碍它们） 1.idea按照docker组件 这个步骤没太多好说的，看图吧 2.修改docker启动服务文件 vi/lib/systemd/system/docker.service ExecStart=/u...

我们在测试服务器上，辛辛苦苦开发，各种配置好了服务，然后想着傻瓜式的迁移部署。接下来的就是干货了 过程描述：为了体现一个完成性的描述，我们最初拉镜像开始，一直说到迁移后的服务正常运行。 接下来以nginx为例，正文开始 1.拉取镜像 获取镜像文件： dockerpullnginx 2.镜像文件对应 没有本地与容器关键性文件映射的容器，没有灵魂啊亲nginx我们对应什么呢通常就是logs文件html即Web对应发布文件etc配置文件这些文件我们不知道在容器中的样子怎么办，先跑一个容器，进去探查一番 测试跑一个容器： dockerrun-d--namenginx01-p80:80ngi...

part1 一、Java操作elasticSearch复杂查询以及解析数据 1.1拆解操作数据 1.2构造一个查询器指向索引 1.3封装查询条件器 1.4封装的条件器置入查询器 1.5容器中的client调用查询： 1.6解析查询结果 1.7打印逐条记录时，可以把结构封装成一个model借助一下：json.cn 1.8完整操作： 二、Java操作elasticSearch索引保存数据 2.1计划与实现 2.2单元测试 2.3执行 2.4查看一下Kibana操作结果 一、Java操作elasticSearch复杂查询以及解析数据 说明：基于银行测试库的操作 es的银行测试库...

前段时间，在做数据治理工作的时候遇到一个问题，ETL抽取数据至了一张没有主键的表，由于ETL源头数据问题，造成了我们的无主键目标表出现了大量的重复数据。不要轻易想着我拿手删吧删吧来处理。整体目标表大概几个亿数据，重复数据高达五六千万。这里讲解一个用Kettle来处理的方案！ 整体的实现思路如下： 输入数据源 基于重复字段数据排序 重复字段条件处理，即合理判定重复数据 数据源输出 场景描述 一、场景描述： 比较庞大的数据中，想要根据一个或者多个字段判别是否位重复数据的去重复操作。 本案例以mysql为案例描述 创造一个id带有重复的数据测试 输入 一、数据源输入菜单中的【...

说明 js正则函数match、exec、test、search、replace、split使用介绍集合,学习正则表达式的朋友可以参考下。 match方法返回的是匹配成功的字符有多少返回多少数组形式 使用正则表达式模式对字符串执行查找，并将包含查找的结果作为数组返回。 stringObj.match(rgExp) 参数 stringObj 必选项。对其进行查找的String对象或字符串文字。 rgExp 必选项。为包含正则表达式模式和可用标志的正则表达式对象。也可以是包含正则表达式模式和可用标志的变量名或字符串文字。 其余说明与exec一样，不同的是如果match的表达式匹配了全局标...

整数或者小数：^[0-9]+\.{0,1}[0-9]{0,2}$ 只能输入数字："^[0-9]$"。 只能输入n位的数字："^\d{n}$"。 只能输入至少n位的数字："^\d{n,}$"。 只能输入mn位的数字：。"^\d{m,n}$" 只能输入零和非零开头的数字："^(0|[1-9][0-9])$"。 只能输入有两位小数的正实数："^[0-9]+(.[0-9]{2})?$"。 只能输入有13位小数的正实数："^[0-9]+(.[0-9]{1,3})?$"。 只能输入非零的正整数："^\+?[1-9][0-9]$"。 只能输入非零的负整数："^\-[1-9][]0-9"$。 只能输入长度...

java相对主流分布式锁redis的Redisson(Javaimplementation) theRedlock设计 1.引入依赖 <!-https://mvnrepository.com/artifact/org.redisson/redisson--> <!-以后试用redisson作为分布式锁，分布式对象等功能框架--> <dependency> <groupId>org.redisson</groupId> <artifactId>redisson</artifactId> <version...

常规操作elasticSearch分词和安装分词器 分词： POST_analyze { "analyzer":"standard", "text":"Todayiswhatsunny." } { "tokens":[ { "token":"today", "start_offset":0, "end_offset":5, "type":"<ALPHANUM>", "position":0 }, { "token":"is", "start_offset":6, "end_offset":8, "type":"<ALPHANUM>", "position":1 ...

常规操作elasticSearch: 对于elasticSearch的操作通常用restAPI完成 查看所有节点： GET： 192.168.31.125:9200/_cat/nodes 示例返回： 127.0.0.11697100.230.560.62dilm6a850788e223 查看健康状态： GET： 192.168.31.125:9200/_cat/health 示例返回： 163529827801:31:18elasticsearchgreen11440000100.0% 查看主节点： GET： 192.168.31.125:9200/_cat/master ...

mysql花式操作数据小结 本文是一片关于一些mysql小技巧的总结。主要内容包括：字段中包含多值、基于字段中某个值查询、基于身份证设置性别、身份证生成出生日期、增加表字段、一次搞定多个查询、关联删除、通过关系表一对多查询合并到一条记录、替代like 1.字段中包含多值 字段为crowd其值：11,32,3,433,4我们把所有3删除然后给他保持原先对队形得到：112,4null4操作： UPDATEsd_o_agreement SETcrowd=trim( BOTH',' FROM REPLACE( concat(',',crowd,','), ',3,'...

CMD启动服务： D:\PostgreSQL\bin pg_ctlregister-NPostgreSQL-D"D:\PostgreSQL\data 登录psql-Upostgres验证输入select1; 拓展：删除服务 scdelete服务名称 PostgreSQL USER: postgres PWD: root PORT: 5432 动PostgreSQL服务器3.1打开命令提示符“Windows”+"R"快捷键打开运行窗口，在输入框中输入"cmd"进入命令行窗口。 图3-1输入"cmd"进入命令行窗口 3.2弹出DOS运行窗口。 PostgreSQL安装目录是"D...