用过JavaScript或者jQuery的同学都知道，JavaScript特别是jQuery中存在大量的回调函数，例如Ajax、jQuery的动画等。
1
2
3
4
5
| 1$.get(url, function() {
2 doSomething1(); // (3)
3}); // (1)
4doSomething2(); // (2)
5 |
1
2
| 1上面的代码是jQuery的Ajax，由于Ajax是异步的，所以在请求URL的过程中并不会阻塞程序，也就是程序运行到（1）并不用等待Ajax请求的结果，就继续往下执行（2）。而$.get的第二个参数是一个回调函数，当Ajax请求完成后，才会调用这个回调函数执行（3）。
2 |
这个例子只是用来理解一下异步的概念，没玩过JS看不懂的同学也没关系。
在传统的IO（BIO/阻塞IO）中，所有IO操作都会阻塞当前线程，直到操作完成，所有步骤都是一步一步进行。例如：
1
2
3
4
5
| 1OutputStream output = socket.getOutputstream();
2out.write(data); // IO操作完成后返回
3out.flush();
4System.out.println("消息发送完成");
5 |
1
2
| 1但是在异步网络编程中，由于IO操作是异步的，也就是一个IO操作不会阻塞去等待操作结果，程序就会继续向下执行。
2 |
在MINA、Netty、Twisted中，很多网络IO操作都是异步的，比如向网络的另一端write写数据、客户端连接服务器的connect操作等。
例如Netty的write方法（以及writeAndFlush方法），执行完write语句后并不表示数据已经发送出去，而仅仅是开始发送这个数据，程序并不阻塞等待发送完成，而是继续往下执行。所以如果有某些操作想在write完成后再执行，例如write完成后关闭连接，下面这些写法就有问题了，它可能会在数据write出去之前先关闭连接：
1
2
3
4
| 1Channel ch = ...;
2ch.writeAndFlush(message);
3ch.close();
4 |
1
2
| 1那么问题就来了，挖掘机...既然上面的写法不正确，那么如何在IO操作完成后再做一些其他操作？
2 |
当异步IO操作完成后，无论成功或者失败，都会再通知程序。至于如何处理发送完成的通知，在MINA、Netty、Twisted中，都会有类似回调函数的实现方式。
Netty：
在Netty中，write及writeAndFlush方法有个返回值，类型是ChannelFuture。ChannelFuture的addListener方法可以添加ChannelFutureListener监听器。ChannelFutureListener接口的抽象方法operationComplete会在write完成（无论成功或失败）时被调用，我们只需要实现这个方法即可处理一些write完成后的操作，例如write完成后关闭连接。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
| 1@Override
2public void channelRead(final ChannelHandlerContext ctx, Object msg)
3 throws UnsupportedEncodingException {
4
5 // 读操作省略...
6
7 // 发送数据到客户端
8 ChannelFuture future = ctx.writeAndFlush("message"); // 返回值类型为ChannelFuture
9 future.addListener(new ChannelFutureListener() {
10
11 // write操作完成后调用的回调函数
12 @Override
13 public void operationComplete(ChannelFuture future) throws Exception {
14 if(future.isSuccess()) { // 是否成功
15 System.out.println("write操作成功");
16 } else {
17 System.out.println("write操作失败");
18 }
19 ctx.close(); // 如果需要在write后关闭连接，close应该写在operationComplete中。注意close方法的返回值也是ChannelFuture
20 }
21 });
22
23}
24 |
1
2
| 1上面代码中，close操作是在operationComplete中进行，这样可以保证不会在write完成之前close连接。注意close关闭连接同样是异步的，其返回值也是ChannelFuture。
2 |
MINA：
MINA和Netty类似，session.write返回值是WriteFuture类型。WriteFuture也可以通过addListener方法添加IoFutureListener监听器。IoFutureListener接口的抽象方法operationComplete会在write完成（无论成功或失败）时被调用。如果需要在write完成后进行一些操作，只需实现operationComplete方法。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
| 1@Override
2public void messageReceived(IoSession session, Object message)
3 throws Exception {
4
5 // 读操作省略...
6
7 // 发送数据到客户端
8 WriteFuture future = session.write("message");
9 future.addListener(new IoFutureListener<WriteFuture>() {
10
11 // write操作完成后调用的回调函数
12 @Override
13 public void operationComplete(WriteFuture future) {
14 if(future.isWritten()) {
15 System.out.println("write操作成功");
16 } else {
17 System.out.println("write操作失败");
18 }
19 }
20 });
21}
22 |
1
2
| 1MINA和Netty不同在于关闭连接的close方法。其中无参数的close()方法已经弃用，而是使用带一个boolean类型参数的close(boolean immediately)方法。immediately为true则直接关闭连接，为false则是等待所有的异步write完成后再关闭连接。
2 |
所以下面这种写法是正确的：
1
2
3
| 1session.write("message");
2session.close(false); // 虽然write是异步的，但是immediately参数为false会等待write完成后再关闭连接
3 |
在Twisted中，twisted.internet.defer.Deferred类似于MINA、Netty中的Future，可以用于添加在异步IO完成后的回调函数。但是Twisted并没有在write方法中返回Deffered，虽然write方法也是异步的。下面就用Twisted实现一个简单的TCP客户端来学习Deffered的用法。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
| 1# -*- coding:utf-8 –*-
2
3from twisted.internet import reactor
4from twisted.internet.protocol import Protocol
5from twisted.internet.endpoints import TCP4ClientEndpoint, connectProtocol
6
7class ClientProtocol(Protocol):
8 def sendMessage(self):
9 self.transport.write("Message") # write也是异步的
10 self.transport.loseConnection() # loseConnection会等待write完成后再关闭连接
11
12# 连接服务器成功的回调函数
13def connectSuccess(p):
14 print "connectSuccess"
15 p.sendMessage()
16
17# 连接服务器失败的回调函数
18def connectFail(failure):
19 print "connectFail"
20
21point = TCP4ClientEndpoint(reactor, "localhost", 8080)
22d = connectProtocol(point, ClientProtocol()) # 异步连接到服务器，返回Deffered
23d.addCallback(connectSuccess) # 设置连接成功后的回调函数
24d.addErrback(connectFail) # 设置连接失败后的回调函数
25reactor.run()
26 |
1
2
| 1在Twisted中，关闭连接的loseConnection方法会等待异步的write完成后再关闭，类似于MINA中的session.close(false)。Twisted中想要直接关闭连接可以使用abortConnection，类似MINA中的session.close(true)。
2 |
作者：叉叉哥 转载请注明出处：http://www.voidcn.com/article/p-hhsmtkqz-mb.html
