- 博客(42)
- 收藏
- 关注
RSS订阅原创 单例模式（双重锁+volatile）
最近在学习Eurake源码（版本为1.7.2），看到源码里面有关于单例模式的，特地记录学习一波。这个代码是在com.netflix.config.ConfigurationManager类里面，下面是部分代码： static volatile AbstractConfiguration instance = null; public static AbstractConfiguration getConfigInstance() { if (instance ==
2021-11-01 21:42:07
372
原创 RocketMQ 延时消息
关键类：DeliverDelayedMessageTimerTask （在RocketMQ的broker 源码中）粗浅的分析了下：我原本关注的是延迟消息如何准时准点的执行：现在我知道了。比如消息的延迟时间是5m,rocketMQ会建立一个定时任务，定时扫描延迟为5m的这个队列，这里如何在消息之间准时到达（严格来说还是有一定的误差，不过从设计上已经控制的很好了），主要逻辑是：遍历延迟队里中的消息，当消息的store时间+延迟时间小于当前时间时，此时将消息投送到原本的队列中； 若此条消息的store时
2021-04-08 08:54:21
352
原创 RocketMQ事物型消息
前提：现有两个微服务A（订单服务）和微服务B（支付服务）。消息具体的流程如下图： 订单服务在执行的时候先向RocketMQ队列发送一个half消息，用来确定MQ的可用性。 在接受到half消息以后，MQ会返回一个成功的响应。 如果此时MQ不可用，那么订单服务就不需要继续执行更新订单的操作了。假设MQ运行正常，订单服务会去执行本地事务完成“更新订单状态”的操作。 订单服务执行的本地事务成功与否，会发给MQ不同的信息。当本地事务成功了，会发送Commit消息，MQ
2021-04-07 08:53:33
167
原创 RocketMQ 双主双从 docker安装在两台虚拟机上
参考了官网（[http://rocketmq.apache.org/docs/quick-start/](http://rocketmq.apache.org/docs/quick-start/）给的配置：在下载好的目录下：rocketmq-all-4.8.0-bin-release\conf\2m-2s-sync 有具体的配置。好了下面讲讲我是怎么在docker上安装好双主双从在两台虚拟机上的，1：默认条件docker已经安装好了我的docker版本Docker version 18.09.0,
2021-04-03 12:12:11
397
1
原创 SpringQueryMap 传递时间格式问题
使用@SpringQueryMap传递一个对象，例如User对象，对象包含以下Date,格式为yyyy-MM-dd@JsonFormat(pattern = "yyyy-MM-dd")@DateTimeFormat(pattern = "yyyy-MM-dd")private Date createTime;在feign 调用时候：期望传递过去的是yyyy-MM-dd格式，实际情况不是，通过查询@SpringQueryMap ，转换对象时是调用@QueryMap#encoded()
2021-03-31 09:38:27
1847
2
原创 postgresql中如何Kill掉正在执行的SQL语句
--查询是否锁表了select oid from pg_class where relname='可能锁表了的表'select pid from pg_locks where relation='上面查出的oid'--如果查询到了结果，表示该表被锁 则需要释放锁定kill有两种方式，第一种是：SELECT pg_cancel_backend(PID);这种方式只能kill select查询，对update、delete 及DML不生效)第二种是：SELECT pg_terminate..
2020-10-09 17:03:44
2837
1
原创 ElasticSearch search_after 分页
search_after 分页的方式和 from - size 分页 相似；在from-size 的基础上 添加 “sort” 将from 去掉{ "size": 10, "query": { "match" : { "title" : "elasticsearch" } }, "sort": [ {"_id": "desc"} ]}然后再第二次查询的时候 添加search_af.
2020-06-03 19:54:52
1564
原创 SpringCloud上传文件，经过Zuul，中文文件名乱码
直接在原有路径 加上zuul比如原有路径：localhost:9090/oss/poi/uploadExcel改为：localhost:9090/zuul/oss/poi/uploadExcel不通过springmvc的上传，直接通过zuul上传
2019-05-24 15:28:41
404
转载 这可能是目前最透彻的Netty原理架构解析
原文链接：http://www.sohu.com/a/272879207_463994链接2：https://blog.csdn.net/hellojackjiang2011/article/details/83748457原文写的很好，我这里就不搬门弄虎了。
2019-02-12 15:55:40
465
1
转载 Dockerfile文件详解
原文链接：https://www.cnblogs.com/panwenbin-logs/p/8007348.html什么是dockerfile?Dockerfile是一个包含用于组合映像的命令的文本文档。可以使用在命令行中调用任何命令。 Docker通过读取Dockerfile中的指令自动生成映像。docker build命令用于从Dockerfile构建映像。可以在docker bu...
2018-12-06 17:45:14
150
原创 使用Dockerfile的方式进行创建镜像
直接进入官网的镜像列表：找到mysql选取dockerfile 我选的是5.7版本的点击后直接跳到Dockerfile去了dockerfile的内容为：FROM debian:stretch-slim# add our user and group first to make sure their IDs get assigned consistently, regard...
2018-12-06 17:08:05
514
原创 ERROR 1045 (28000): Access denied for user 'ROOT'@'localhost' (using password: YES)
docker 运行mysql 出现如下错误：ERROR 1045 (28000): Access denied for user 'ROOT'@'localhost' (using password: YES)拉去的是官方的镜像，我一直认为是运行mysql的时候哪里出现了问题，这是我运行的语句：sudo docker run -d --name mysql5.7 -e MYS...
2018-12-06 14:06:12
994
转载 ubantu14.04 安装docker
原文链接：https://www.cnblogs.com/leolztang/p/5097278.htmlDocker官方是有很详细的安装文档（https://docs.docker.com/engine/installation/ubuntulinux/），这里做了一个Ubuntu 14.04 LTS中文版的。系统要求64位$ file /sbin/init/sbin/init...
2018-12-05 09:52:34
140
转载 centos7上安装docker
原文链接：https://www.cnblogs.com/yufeng218/p/8370670.htmlDocker从1.13版本之后采用时间线的方式作为版本号，分为社区版CE和企业版EE。社区版是免费提供给个人开发者和小型团体使用的，企业版会提供额外的收费服务，比如经过官方测试认证过的基础设施、容器、插件等。社区版按照stable和edge两种方式发布，每个季度更新stable版本...
2018-11-25 10:35:59
126
原创 VIM 的三种模式和跳到指定的行数
3种操作模式：1、一般模式vim filenamevim进入文件之后就是一般模式，该模式只能查看文档2、编辑模式进入一般模式之后输入i（insert）进入编辑模式按esc退出编辑模式，进入一般模式3、命令模式在一般模式下输入:进入命令模式输入下列命令回车：-q！ 不保存修改退出-wq 保存修改并退出-set number 显示行数-set nonumber 取消显...
2018-09-28 17:47:00
4702
转载 linux修改时间和时区
原文链接：https://www.cnblogs.com/xiaojianblogs/p/8949932.html linux系统时间有两个，一个是硬件时间，即BIOS时间，就是我们进行CMOS设置时看到的时间，另一个是系统时间，是linux系统Kernel时间。当Linux启动时，系统Kernel会去读取硬件时钟的设置，然后系统时钟就会独立于硬件运作。有时我们会发现系统时钟和硬件时钟...
2018-08-21 17:48:08
138
原创 Springboot 取yml文件中的数组
list: li: - 11 - 13 @Component@ConfigurationProperties(prefix="list")public class IgnoreImageIdConfig { private List<Integer> li =new ArrayList<Integer>(); public Li...
2018-08-20 12:52:56
26689
2
原创 记录一次JNA调用c的内存异常
因为在项目中需要调用c，用到了JNA,运行项目是没有问题的，但是跑多了程序就直接崩溃，想来想去，还是没有思路，作为Java开发，很少有自己手动释放内存的习惯，因为JVM已经替我们做了，但是利用JNA掉用的时候涉及到了C，不会自动释放内存，需要手动释放内存。在此记录此坑。以下是手动释放内存的例子。 public String getHostName() throws LibvirtExc...
2018-08-13 19:24:59
2630
转载 Kafka查看topic、consumer group状态命令
原文链接：https://www.cnblogs.com/AcAc-t/p/kafka_topic_consumer_group_command.html最近工作中遇到需要使用kafka的场景，测试消费程序启动后，要莫名的过几十秒乃至几分钟才能成功获取到到topic的partition和offset，而后开始消费数据，于是学习了一下查看kafka broker里topic和consumer g...
2018-08-06 11:08:23
40437
1
转载 Spring中的@Async
原文链接：https://www.cnblogs.com/wihainan/p/6516858.html在Java应用中，绝大多数情况下都是通过同步的方式来实现交互处理的；但是在处理与第三方系统交互的时候，容易造成响应迟缓的情况，之前大部分都是使用多线程来完成此类任务，其实，在spring 3.x之后，就已经内置了@Async来完美解决这个问题 1. 何为异步调用？ 在解释...
2018-07-26 18:22:01
93
转载 spring boot 集成kafka (多线程,消费者使用kafka的原生api实现,因为@KakfkaListener修改groupId无效)
原文链接：http://www.mamicode.com/info-detail-2078498.html1 #kafka 2 kafka.consumer.zookeeper.connect=*:2181 3 kafka.consumer.servers=*:9092 4 kafka.consumer.enable.auto.commit=true 5 kafka.consumer...
2018-07-25 10:45:02
8663
转载 Disruptor并发框架 （之）核心概念场景分析
原文链接：https://www.cnblogs.com/jiangjun-x/p/8111513.html超级赞的原文链接：https://www.jianshu.com/p/f4021e8141ad核心术语RingBuffer(容器): 被看作Disruptor最主要的组件，然而从3.0开始RingBuffer仅仅负责存储和更新在Disruptor中流通的数据。对一些特殊的使用场景...
2018-07-24 17:17:18
297
转载 KAFKA学习记录
kafka的消息是用文件的形式存储在磁盘空间的，理论上只要磁盘空间无线大，就可以存储消息，但实际上是设置kafka消息的时间，来定期删除过期的消息， 1 启动advertised.listeners配置异常:java.lang.IllegalArgumentException: requirement failed: advertised.listeners cannot ...
2018-07-24 16:27:40
2750
原创 Redis 集群之 ruby安装
利用rvm安装$ gpg --keyserver hkp://keys.gnupg.net --recv-keys 409B6B1796C275462A1703113804BB82D39DC0E3## 可能需要' gpg2 '和或者' sudo '.curl -L get.rvm.io | bash -s stablesource ~/.rvm/scripts/rvmrvm ...
2018-07-24 16:24:40
194
转载 Nginx编译参数大全 configure参数中文详解
原文链接：https://www.jb51.net/article/49049.htmNginx编译参数：./configure --help--help 显示本提示信息--prefix=PATH 设定安装目录--sbin-path=PATH 设定程序文件目录--conf-path=PATH 设定配置文件(nginx.conf)目录--error-log-path=PATH 设定错...
2018-07-24 16:18:55
230
原创 Ubuntu下Nginx安装
1、选的目录本人选定的时根目录下的/usr/local/nginx目录2、安装依赖以下所有的操作都在/usr/local/nginx目录下进行 安装openssl，版本自己选#下载wget https://www.openssl.org/source/openssl-1.1.0e.tar.gz#解压tar zxvf openssl-1.1.0e.tar.gz#进目录c...
2018-07-24 16:04:47
151
转载 UBANTU 软件依赖的问题
原文链接:http://blog.csdn.net/smallmao/article/details/45626555ubuntu下apt-get install安装软件, 报“无法修正错误,因为您要求某些软件包保持现状,就是它们破坏了软件包间的依赖关系”,今天终于找到解决方法了。一般出现这种情况的原因时 要装A, 依赖B, 但是已经安装的软件C也依赖B, 但是A依赖的B的版本和C依赖的B...
2018-07-23 17:22:59
329
原创 kafka 服务端常用命令
从控制台查看topic中的数据bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning查看kafka的已有的topicbin/kafka-topics.sh --list --zookeeper localhost:2181创建新的topicbin/kafk...
2018-07-18 22:29:13
971
转载 KAFKA 集群搭建
原文链接：https://blog.csdn.net/maomao5987370/article/details/51384694针对自己的版本（kafka_2.10-0.10.2.1）做了些小的调整Kafka 0.9集群安装配置操作系统：.UBANTU14.041. 安装Java环境 Zookeeper和Kafka的运行都需要Java环境，所以先安装JRE，Kafka默...
2018-07-18 17:33:08
328
原创 linux手动安装sbt过程
原文链接：https://www.cnblogs.com/wrencai/p/3867898.htmlubuntu14 手动安装sbt 参见官网配置说明http://www.scala-sbt.org/release/tutorial/Manual-Installation.html 1、下载sbt通用平台压缩包：sbt-0.13.5.tgz http://www.sc...
2018-07-18 16:28:37
410
转载 zookeeper单机模式，伪分布式，集群模式安装教程（按照步骤来，100%能成功）
原文链接：https://blog.csdn.net/Poppy_Evan/article/details/79487418
2018-07-18 11:06:30
132
转载 kafka调试中遇到Connection to node -1 could not be established. Broker may not be available.
原文链接：https://blog.csdn.net/getyouwant/article/details/79000524kafka报错内容：WARN [Consumer clientId=consumer-1, groupId=console-consumer-950] Connection to node -1 could not be established. Broker may...
2018-07-17 23:27:06
34818
1
转载 基于shell脚本中cd命令无效的解决方法
原文链接：https://blog.csdn.net/czg13548930186/article/details/72861086在学习的时候，经常要切换到固定的文件夹，于是写了个shell脚本用cd命令切换却发现目录切换不了。代码如下：#! /bin/bash# c.shcd /mnt/hgfs/vmsharepwd解释：执行的时候是./c.sh来执行的，这样执行的话...
2018-07-17 14:23:45
1630
转载 String.format()的用法
package junit.test; import java.util.Date;import java.util.Locale; import org.junit.Test; public class StringFormat { /*String.format()用法 1、转换符%s: 字符串类型，如："ljq"%b: 布尔类型，如：true%d: 整数类型(十...
2018-06-19 22:18:45
173
原创 kafka下载注意事项
在官网上下载kafka一定要下载2.11 版本的，2.12版本的启动时可能会有问题，我就是在这个坑里爬了半天的那个人下面附上kafka官网的链接（里面有官方参考文档）http://kafka.apache.org/downloads...
2018-06-15 15:05:03
746
原创 （zookeeper启动问题）Error contacting service. It is probably not running.
Error contacting service. It is probably not running.（这个的原因有很多种，下面是ubantu系统下的问题）使用ubantu时安装zookeeper会出现这个问题，在zkServer.sh的头部加上export JAVA_HOME=/usr/local/java/jdk1.8.0_11export PATH=$JAVA_HOME/bin:$PAT...
2018-06-14 17:40:30
462
空空如也
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人