xiaoZ5919
- 浏览: 400430 次
- 性别:
- 来自: 安平人@北京
-
博客专栏
-
-
Netty学习笔记
浏览量：72762
最新评论
-
sunnyhappylg：
问题：一个已经在线的redis集群 如何进行升级，需要把整个集 ...
Redis Cluster的FailOver失败案例分析 -
whmwg：
...
jdbctemplate与事务管理 -
facebook1314：
请问后台的HessianService能发布成多线程模式么(p ...
spring使用注解暴露remoting服务 -
wangyujie0431：
zhouwm402 写道我也是：service里面的dao没法 ...
spring使用注解暴露remoting服务 -
lcwen_13：
Scanner貌似是重复造轮子的赶脚
spring使用注解暴露remoting服务
文章列表
ThreadPool的优点，比如资源的控制以及不用频繁的创建线程等就不用多说了。主要来讨论一下ThreadPoolExecutor的几个关键参数以及对task的添加以及线程的管理。它有这么个重要的参数corePoolSize、maximumPoolSize、keepAliveTime和taskqueue。
corePoolSize 线程池维持处于Keep-alive状态的线程数量。如果设置了allowCoreThreadTimeOut为true，该值可能为0。
maximumPoolSize 线程池中可维持线程的最大值。
keepAliveTime 当线程池中线程数量大于 ...
ReplayingDecoder的原理是阻塞IO，当没有读到足够的数据时，会抛出RelayError，进入以后的LOOP中不断check是否有足够的数据。因此每次读取时我们倒要check一下buffer的数据。为此Netty提供了ReplayingDecoderBuffer这样一个代理类封装原有的buffer。以readInt为例，首先要检查是否有4个字节可读。不满足抛出ReplayError。
@Override
public int readInt() {
checkReadableBytes(4);
return buffer ...
为什么需要ReplayingDecoder，它和FrameDecoder有什么不同呢?ReplayingDecoder是一种特殊FrameDecoder，它能实现在IO阻塞的情况下实现无阻塞的解码。听起来比较拗口而且不好理解，举个例子来说，假设你在用netty设计一个文件传输的模块，采用的Header-Content的协议，在Header中说明文件的长度，我们用一个int来容纳长度，Content则是该int长度的字节数组。该如何设计这个Decoder呢？代码有可能是下面这样的。可能你会觉得比你想象的要复杂，多了markReadIndex(),多了是否可读的判断，假如读一个int，我们得首先 ...
书接上回，上次说到了selector的register和select会有锁冲突，这次再来考虑write的问题。
1. channel.write(Bytebuffer)是不是总是可写，当socket的writeBuffer满的时候会返回0，说明不能再写进任何字节。假设要写入一个很大的ByteBuffer，有可能需要分多次写。
2. channel上执行write操作需要获得锁保证同步，如果用户在应用代码中多处同时执行则会有锁竞争。
我们知道NIO是无阻塞同步的IO，无阻塞说的是读或者写的就绪状态。一般来说写的流程是这样的，使channel对write感兴趣，然后轮询sel ...
研究了一段时间Nio框架,有Netty和Tomcat的Nio Connector总结了一些共性的问题的解决方案。
1. Selector的register和select有锁冲突，例如tomcat的Nio Connector，他采用的Acceptor和Poller的模式，Acceptor只负责接收socket，Poller是负责读写的IO线程，这种模式不用于nginx，Poller（worker）既负责接收和读写的抢占式模块。这样Acceptor和Poller存在的一个交互就是register，Acceptor需要把接收到的socket注册给Poller。Poller实现了Sel ...
spring提供了多种序列化方式的基于http协议的rometing服务并且在使用的接口方式，服务端使用Exporter，客户端使用FactoryBean，例如hessian的HessianExporter和HessianProxyFactoryBean。exporter有两个参数比较关键一个是serviceInterface，另外一个是service bean本身。无论是HessianExporter还是HttpInvokerExporter都需要配置这两参数，目前spring是在配置文件中进行配置：
<bean id="helloService" cla ...
FrameDecoder是Netty Protocol Decode最关键的Decoder，几乎所有和协议解码相关的Decoder都继承自它，那到底解决了什么问题？为什么需要这样的一个部件呢？TCP的传输是基于流的，每个数据包都有可能被分片和然后重组，这时候我们就需要协议去界定一个数据包，通常来说用来方式来确定数据包的边界，一个是基于长度，简单一点就是规定数据包的长度，例如规定每个数据包的长度为100byte，FixedlengthFrameDecoder就是这样，可实际中我们的数据包并不都是固定长度，可以说是大小不一的情况更常见。怎么样解决这个问题呢？我们加一个长度属性的header ...
话说Connect reset异常
- 博客分类：
- java
起因是这样的，线上log经常出现Connection Reset异常，从堆栈上分析是solr进行sharding request时发生的，solr部署在tomcat上。从现场来看，原因很明白Server端发出RST包。但具体原因是什么就得经过一番分析了，
经过google百度以及和网友沟通，发现会有以下场景导致RST：
1. 设置SoLinger，并设置停留时间为0
显然不是这样的场景，如是则会经常出现，而不是偶尔出现。还有其他的吗？我翻看了一下TCP/IP详解，TCP的连接与终止以及复位报文段。有点收获但还是没有看太懂，呵呵答案就在书上，也许没有沉 ...
昨日和公司同事分享Netty入门的时候，讨论了如下两个问题：
1. Select的最大轮询数限制是1024
2. 当超过1024以后还能注册吗？ 或者如何突破1024的限制
我昨天又查阅了一番文档，select最大轮询数不一定是1024，而是FD_SET这个参数，如FD_SET设置为128，则最大轮询数为128。一般为FD_SET的值设置为1024，为什么不设更大的值，应该是处于性能的考虑，轮询数越多，轮询一次的时间也就越长。
如何突破FD_SET的限制？
有两种方式可以突破FD_SET的限制
1.网上介绍的。修改 ...
数据结构支持： 双向循环链表
改造过程：
1，在LinkedHashMap的初始化过程添加一个dumy的header双向链表头
2，在Entry添加before和after
过程演示：
1. dumy的header
before(header)<----header --->after(header)
2. 插入第一个entry
entry1
...
ReentrantLock为啥会出现不公平的场景
- 博客分类：
- java
不公平锁产生的原因的是acquire在enqueue之前，这样后来的线程有可能会较在等待队列中的等待者之前获得锁。barging这个词可以理解为闯入，插队。不公平锁会导致某些线程总是不排队就获得锁，而同时排在队尾的线程总是出现饥饿状态。那么如何获取公平锁呢，Doug Lee页给出了方案，很简单在acquire的时候，首先检查当前线程是否在队列中（对首），如在队列中即可获得，如不在队列中，则乖乖得排在队尾睡大觉(parking)等着排在前面的线程叫醒它(unparking)。
公平锁为啥会影响性能，从code上来看看公平锁仅仅是多了一项检查是否在队首会影响性能，如不 ...
releaseConnection是close connection，基于连接池的认识，我们首先会想到是释放链接，至于是否close就不得而知了。近日发现线上系统出现了close wait的socket，close wait是由于被动关闭的一方没有执行socket.close()导致，由此可见我们code中存在没有正确关闭socket。
类似的code是这样的
HttpClient httpClient = newHttpClient();
GetMethod getMethod = new GetMethod();
httpclient.execute(getMet ...
结论： register得放在select之前进行
Thread Dump信息：
"Poller-1" prio=6 tid=0x040f0400 nid=0x408 runnable [0x044df000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.WindowsSelectorImpl$SubSelector.poll0(Native Method)
at sun.nio.ch.WindowsSelectorImpl$SubSelector.poll(Windo ...
Criteria的Order功能简洁，只支持按照某个属性(字段)的排序，如果想要实现order by min(id) 这样的应用场景就没戏儿了，起初我想用interceptor的onPrepareStatement()修改sql，但受困于spring管理事务，如用interceptor就得所用的session都使用interceptor，而不能做到灵活使用。我们知道projection和Restrictions都支持嵌入某个sql片段，我们就参照他们实现一个吧具体代码如下：public class UDOrder extends Order {
private Strin ...
join：调用线程等待被调用线程执行结束方可执行下面的操作，使用的场景如下，主线程需要调用一个线程A去异步执行一个操作，同时主线程必须等到线程A执行完毕才能执行，join就派上用场了。
具体实现也简单，通过一个线程来判断线程A时候执行完成，用isAlive()判断，如果依然在执行（存活）,调用线程A的wait()使主线程等待。
public final synchronized void join(long millis)
throws InterruptedException {
long base = System.currentTi ...