初识java之Mina（一）

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.");
	}
}

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("//");
					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");
	}
}