flychao88
- 浏览: 753254 次
- 性别:
- 来自: 北京
-
最新评论
-
萨琳娜啊：
Java读源码之Netty深入剖析网盘地址：https://p ...
使用JAVA操作netty框架 -
小灯笼：
Netty源码剖析视频教程网盘地址：https://pan.b ...
使用JAVA操作netty框架 -
luckywind：
请问怎么下载那个svn上的源码啊？
本地调试Hbase源码详解 -
heng123：
Netty视频教程https://www.douban.com ...
使用JAVA操作netty框架 -
kongdong88：
Netty简单应用与线上服 ...
使用JAVA操作netty框架
文章列表
【转】RPC技术简介
- 博客分类：
- java基础
思考一下分布式系统中的 RPC (Remote Procedure Call) 问题，一个完整的 RPC 模块需要可以分为三个层次
服务层（service）：RPC 接口定义与实现
协议层（protocol）：RPC 报文格式和数据编码格式
传输层（transport）：实现底层的通信（如 socket）以及系统相关的功能（如事件循环、多线程）
在实际的大型分布式系统中，不同的服务往往会使用不同的语言来实现，所以一般的 RPC 系统会提供一种跨语言的过程调用功能，比如一段用C++实现的客户端代码可以远程调用一个用 Java 实现的服务。实现跨语言 RPC 有两种方法：
静态代 ...
java平台一直对并发程序设计和多线程有这很好的支持。但在早期这种支持也只是在应用层调用原生结构，这种方式最大的缺陷就是使这些原始构件有效的被调用；否则，应用将不能正确运行或者不能达到期望结果。
Executor框架自java1.5中被作为comcurrency包的一部分被引入。它是java多线程的一个抽象层实现，并且作为java中首个实用的并发框架被用来标准调用、在并行线程中调度、执行以及控制异步任务。执行规则在创建构造器的时候就已经被定义，之后executor按照之前设置好的规则来调用并发线程。
1、client一个线程调用远程接口，生成一个唯一的ID（比如一段随机字符串，UUID等），Dubbo是使用AtomicLong从0开始累计数字。
2、将打包的方法调用信息（如调用的接口名称，方法名称，参数值列表等），和处理结果的回调对象callback，全部封装在一起，组成一个对象object。
3、向专门存放调用信息的全局ConcurrentHashMap里面put(ID, object)。
4、将ID和打包的方法调用信息封装成一对象connRequest，使用IoSession.write(connRequest)异步发送出去。
5、当前线程再使用cal ...
项目用到了ApplicationContextAware，通过它Spring容器会自动把上下文环境对象调用ApplicationContextAware接口中的setApplicationContext方法。
我们在ApplicationContextAware的实现类中，就可以通过这个上下文环境对象得到Spring容器中的Bean。
使用方法如下：
1.实现ApplicationContextAware接口：
package com.bis.majian.practice.module.spring.util;
今天早上一上班，有同事就反映公司好几个网站都打不开，登陆数据库
服务器(windows)，发现很卡,于是重启了下服务器，进入系统后，没过一会问题依旧,查看了下系统进程，发现mysql占用率达到99%，可以肯定的是mysql连接出现问题:
netstat -an
192.168.12.13:3306 192.168.12.12:30443 TIME_WAIT
192.168.12.13:3306 192.168.12.12:30444 TIME_WAIT
192.168.12.13:3306 192.168.12.12: ...
写NIO程序经常使用ByteBuffer来读取或者写入数据，那么使用ByteBuffer.allocate(capability)还是使用ByteBuffer.allocteDirect(capability)来分配缓存了？第一种方式是分配JVM堆内存，属于GC管辖范围，由于需要拷贝所以速度相对较慢；第二种方式是分配OS本地内存，不属于GC管辖范围，由于不需要内存拷贝所以速度相对较快。
我们肯定想选择比较快的，但问题是直接内存不属于GC管辖范围，需要弄清楚这部分内存如何管理，否则造成内存泄露就麻烦了。本地内存在JAVA中有一个对应的包装类DirectByteBuffer ...
火车运煤算法--全面解析
- 博客分类：
- java基础
你是山西的一个煤老板，你在矿区开采了有3000吨煤需要运送到市场上去卖，从你的矿区到市场有1000公里，你手里有一列烧煤的火车，这个火车最多只能装1000吨煤，且其能耗比较大――每一公里需要耗一吨煤。请问，作为一个懂编程的煤老板的你，你会怎么运送才能运最多的煤到集市？
这道题一开始看上去好像是无解的，因为你的火车每一公里就要消耗一吨煤，而到目的地有1000公里，而火车最多只能装1000吨媒。如果你的火车可以全部装下，到目的地也会被全部烧光，一丁点也不剩。所以，很多人的第一反应都是觉得这个不太可能。
思考答题是：
装1000吨煤，走250公里，扔下500吨煤，回矿山。
装 ...
NIO 水平触发，边缘触发的区别
- 博客分类：
- java基础
在linux的IO多路复用中有水平触发,边缘触发两种模式,这两种模式的区别如下:
水平触发:如果文件描述符已经就绪可以非阻塞的执行IO操作了,此时会触发通知.允许在任意时刻重复检测IO的状态,没有必要每次描述符就绪后尽可能多的执行IO.select,poll就属于水平触发.
边缘触发:如果文件描述符自上次状态改变后有新的IO活动到来,此时会触发通知.在收到一个IO事件通知后要尽可能多的执行IO操作,因为如果在一次通知中没有执行完IO那么就需要等到下一次新的IO活动到来才能获取到就绪的描述符.信号驱动式IO就属于边缘触发.
epoll既可以采用水平触发,也 ...
Spring AOP 源码实现过程
- 博客分类：
- 开发框架
我们看看在Spring AOP中拦截器链是怎样被调用的，也就是Proxy模式是怎样起作用的，或者说Spring是怎样为我们提供AOP功能的；
在JdkDynamicAopProxy中生成Proxy对象的时候：
return Proxy.newProxyInstance(classLoader, proxiedInterfaces, this);
这里的this参数对应的是InvocationHandler对象,这里我们的JdkDynamicAopProxy实现了这个接口，也就是说当Proxy对象的函数被调用的时候，这个InvocationH ...
【转】Java常见内存溢出异常分析
- 博客分类：
- java基础
Java虚拟机规范规定JVM的内存分为了好几块，比如堆，栈，程序计数器，方法区等，而Hotspot jvm的实现中，将堆内存分为了三部分，新生代，老年代，持久带，其中持久带实现了规范中规定的方法区，而内存模型中不同的部分都会出现相应的OOM错误，接下来我们就分开来讨论一下。
栈溢出(StackOverflowError)
栈溢出抛出java.lang.StackOverflowError错误，出现此种情况是因为方法运行的时候栈的深度超过了虚拟机容许的最大深度所致。
出现这种情况，一般情况下是程序错误所致的，比如写了一个死递归，就有可能造成此种情况。 下面我们通过一段代码来模拟一下此种情况 ...
1、随机：负载均衡方法随机的把负载分配到各个可用的服务器上，通过随机数生成算法选取一个服务器，然后把连接发送给它。虽然许多均衡产品都支持该算法，但是它的有效性一直受到质疑，除非把服务器的可运行时间看的很重。
2、轮询：轮询算法按顺序把每个新的连接请求分配给下一个服务器，最终把所有请求平分给所有的服务器。轮询算法在大多数情况下都工作的不错，但是如果负载均衡的设备在处理速度、连接速度和内存等方面不是完全均等，那么效果会更好。
3、加权轮询：该算法中，每个机器接受的连接数量是按权重比例分配的。这是对普通轮询算法的改进，比如你可以设定：第三台机器的处理能力是第一台机器的两倍，那么负载均 ...
Reactor这个词译成汉语还真没有什么合适的，很多地方叫反应器模式，但更多好像就直接叫reactor模式了，其实我觉着叫应答者模式更好理解一些。通过了解，这个模式更像一个侍卫，一直在等待你的召唤，或者叫召唤兽。
并发系统常使用reactor模式，代替常用的多线程的处理方式，节省系统的资源，提高系统的吞吐量。
先用比较直观的方式来介绍一下这种方式的优点，通过和常用的多线程方式比较一下，可能更好理解。
以一个餐饮为例，每一个人来就餐就是一个事件，他会先看一下菜单，然后点餐。就像一个网站会有很多的请求，要求服务器做一些事情。处理这些就餐事件的就需要我们的服务人员了。
...
【经验总结】NIO常见的陷阱解析
- 博客分类：
- java基础
NIO编程很容易吗?不容易吗？很容易吗？不容易
吗？……
有些陷阱你需要知道
陷阱1：处理事件忘记移除key
在select返回值大于0的情况下，循环处理
Selector.selectedKeys 集合，每处理一个必须移除
Iterator<SelectionKey> it=set.iterator();
While(it.hasNext()){
SelectionKey key=it.next();
it.remove(); //切记移除
……处理事件
}
不移除的后果是本次的就绪的key集合下次会再次返
回,导致无限循 ...