huangjianlin
- 浏览: 32378 次
- 性别:
- 来自: 广州
-
最新评论
-
dreamstoney：
[size=small][flash=200,200][img ...
JSON格式解析 .
文章列表
NettY 文件上传例子
- 博客分类：
- 网络编程
package bhz.netty.upload;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.Channel;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.logging.LogLevel;
i ...
Netty 文件下载例子
- 博客分类：
- 网络编程
package bhz.netty.httpfile;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
impo ...
package bhz.netty.heartBeat;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import ...
netty 超时重连列子
- 博客分类：
- 网络编程
package bhz.netty.runtime;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.n ...
package bhz.netty.ende1;
import java.nio.ByteBuffer;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
impo ...
netty第二个HelloWord例子
- 博客分类：
- 网络编程
package bhz.netty.helloworld;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io ...
第一个NETTY例子
- 博客分类：
- 网络编程
package netty1;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel ...
package com.bjsxt.height.lock021;
import java.util.concurrent.locks.ReentrantReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock;
import java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock;
/**
* 口诀：读读共享，读写，写写互斥
*
*/
public class UseReentrantReadWr ...
package com.bjsxt.height.lock020;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class UseManyCondition {
private ReentrantLock lock = new ReentrantLock();
private Condition c1 = lock.newCondi ...
package com.bjsxt.height.lock020;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class UseCondition {
private Lock lock = new ReentrantLock();/ ...
package com.bjsxt.height.concurrent019;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
/**
* 可以控制系统的流量，拿到信号量的线程可以进入，否则等待。
通过 acquire（）、release（）获取和释放访问许可。
*
*/
public class UseSemaphore {
...
路径：http://www.importnew.com/21889.html
package com.bjsxt.height.concurrent019;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;
/**
* future模式非常适合在处理很耗时的业务逻辑中使用，可以减少系统的响应时间，提供系统吞吐量。
* 真正进行业务逻辑处理的类必须实现Callable接口，重写 ...
package com.bjsxt.height.concurrent019;
import java.util.concurrent.CountDownLatch;
/**
* CountDownLatch类位于java.util.concurrent包下，利用它可以实现类似计数器的功能。
* 比如有一个任务A，
* 它要等待其他4个任务执行完毕之后才能执行，此时就可以利用CountDownLatch来实现这种功能了
*
*/
public class UseCountDownLatch {
public static void main(Strin ...
package com.bjsxt.height.concurrent018;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concur ...