- 博客(18)
- 收藏
- 关注
RSS订阅原创 rocketMQ-consumer源码
RocketMQ 服务器与消费之之前的消息传送方式分为拉模式和推模式，其中推模式是基于拉模式实现的，一个拉取任务完成之后立刻开始下一个拉取任务。消费模式分为集群消费（clustering）和广播消费（broadcasting）。集群模式，同一个主题下的同一条消息只能被一个集群中的一个消费者消费；广播模式，同一个主题下的同一条消息要被集群中所有消费者消费。启动以DefaultMQPus...
2019-04-15 22:42:58
432
1
原创 rockeMQ-producer源码
DefaultMQProducerImpl启动start方法producerGroup如果不是CLIENT_INNER_PRODUCER，并且intanceName=DEFAULT，则把instanceName改为PIDmQClientFactory是一个MQClientInstance对象，由MQClientManager管理，这是一个单例，其中ConcurrentMap<...
2019-03-15 18:17:18
304
1
原创 rocketMQ消息存储源码
MapedFilepublic static final int OS_PAGE_SIZE= 1024 * 4; —操作系统每页大小，默认4Kprivate static final AtomicLong TOTAL_MAPPED_VIRTUAL_MEMORY= new AtomicLong(0); —当前JVM中已经map的虚拟内存private static final Atomic...
2019-03-14 19:25:34
427
1
原创 sublime text3 markdown
sublime text3 markdown插件1.markdown editing用于markdown编辑，高亮。 安装： command+shift+p->输入 install－>输入markdown editing->安装使用： view->syntax->Markdown Editing->markdown2.markdo...
2018-08-03 14:30:30
369
1
原创 Mac OS解决JAVA版本问题
最近安装了jdk8之后，PATH，JAVA_HOME,~/.bash_profile文件都配置好了版本，指向新安装的1.8，但是不管是IDE还是MVN命令编译代码总是不通过，报错：无效的目标发行版: 1.8。执行java －version显示版本是1.8，但是javac －version版本是1.7。 执行which javac 居然显示的是1.8下面的bin。 百思不得其解。百度了半天...
2018-07-05 19:55:35
1980
1
原创 Spring boot用jar包注册service服务
最近项目用到spring boot，看了官方文档，可以把spring boot的jar包安装为一个service，直接用service serviceName start/stop/status/restart来控制。还可以设置开机自动启动，这样可以防止进程被杀掉。 可以： 1. Starts the services as the user that owns the jar file 2...
2018-04-26 14:18:09
1683
原创 spring全局异常处理作用机制
最近遇到spring MVC中异常捕获的问题，比较好奇spring是怎么catch住exception然后调用exceptionHandler中的方法的。发现真相原来这么简单。。。。居然直接用的是try catch。根据源码可以看出，要实现异常拦截，可以实现一个类实现HandlerExceptionResolver 和Ordered 接口，后者主要用于排序，在spring容器中申明就可以了。...
2018-02-09 16:14:05
575
原创 Oracle执行计划总结
Oracle优化器RBO rule based optimization:基于规则的优化器，对数据不敏感CBO cost based optimization 基于代价的优化器，会计算执行代价，选出最优化的策略执行计划Table Access ByTable access full 全表扫描Table access by rowid ； rowId是oracle给
2018-02-06 11:04:19
454
原创 Java异步Future详解
简介Future主要用于有返回值的异步任务。最核心的类是FutureTask，它是Future接口唯一的实现类。FutureTask 可以看出FutureTask类实现了Runnable和Future接口。 内部属性有 private volatile int state; private Callable<V> callable; /...
2018-02-05 22:07:19
3313
原创 spring定时任务详解
使用很方便的使用方法是用@Scheduled注解，在Spring配置文件中加入相应的配置。其中ThreadPoolTaskScheduler的poolSize属性代表用于执行定时任务的线程数。例如有两个定时任务触发的时间相同，如果只有一个线程，那么有一个任务需要等到另一个任务执行完了才能执行，如果线程数是2则可以并行执行。task:annotation-driven executo
2018-02-02 18:10:27
4293
原创 Mybatis Select...for update用法
Mybatis Select…for update用法最近有需求批量处理大量数据，由于数据量很大，如果加分布式锁让一个线程跑需要太长时间，所以考虑集群中二十几台机器并行执行，每次取1000条数据处理。选择了使用select…for update悲观锁，每次把取出来的1000条数据加锁之后更改状态字段再commit，从而保证所有线程不重复取数据。很容易想到的用法就是把select for upate和
2017-10-13 15:58:09
30275
9
原创 swagger 的使用
首先在 swagger editer 里写好doc 选择下载为json文件把这个json文件放在tomcat的 root 目录下 下载swagger ui 的source 放在tomcat的root目录下 并且修改 swagger-ui-master/index.html中的 $(function () { var url = window.location.sear
2014-12-10 00:05:45
4730
1
空空如也
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人