Apache Mina Server 是一個(gè)網(wǎng)絡(luò)通信應(yīng)用框架，也就是說(shuō)，它主要是對(duì)基于 TCP/ip、UDP/IP協(xié)議棧的通信框架（當(dāng)然，也可以提供 JAVA 對(duì)象的序列化服務(wù)、虛擬機(jī)管道通信服務(wù)等），Mina 可以幫助我們快速開發(fā)高性能、高擴(kuò)展性的網(wǎng)絡(luò)通信應(yīng)用，Mina 提供了事件驅(qū)動(dòng)、異步（Mina 的異步 IO 默認(rèn)使用的是 JAVA NIO 作為底層支持）操作的編程模型。

首先先寫個(gè)簡(jiǎn)單的server，來(lái)實(shí)現(xiàn)異步的文件上傳。

public class Main {PRivate static final int PORT = 8080;public static void main(String[] args) throws Exception {NioSocketAcceptor accept = new NioSocketAcceptor();accept.getFilterChain().addLast("codec",new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));accept.getFilterChain().addLast("logging", new LoggingFilter());accept.setHandler(new FileUploadHandler());accept.bind(new InetSocketAddress(PORT));System.out.println("upload  server started.");}}

handle的處理就狠簡(jiǎn)單了。

public class FileUploadHandler extends IoHandlerAdapter {private BufferedOutputStream out;private int count;private static final Log log = LogFactory.getLog(FileUploadHandler.class);public void sessionOpened(IoSession session) throws Exception {System.out.println("server open");public void exceptionCaught(IoSession session, Throwable cause)throws Exception {System.out.println("exception");session.close(true);super.exceptionCaught(session, cause);}public void messageReceived(IoSession session, Object message) {System.out.println("server received");try {if (message instanceof FileUploadRequest) {FileUploadRequest request = (FileUploadRequest) message;System.out.println(request.getFilename());if (out == null) {String [] array = request.getFilename().split("http://");System.out.println(array[1]);out = new BufferedOutputStream(new FileOutputStream("D://"+array[1]));out.write(request.getFileContent());} else {out.write(request.getFileContent());}count += request.getFileContent().length;} else if (message instanceof String) {if (((String) message).equals("finish")) {System.out.println("size is " + count);out.flush();out.close();out = null;session.write("success");}}} catch (Exception e) {e.printStackTrace();}}public void sessionClosed(IoSession session) throws Exception {System.out.println("server session close");}}