Apache MINA java UDP例子|byte数组

package com; import java.io.IOException; import java.net.InetSocketAddress; import java.util.concurrent.Executor; import java.util.concurrent.Executors; import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder; import org.apache.mina.filter.executor.ExecutorFilter; import org.apache.mina.transport.socket.DatagramSessionConfig; import org.apache.mina.transport.socket.nio.NioDatagramAcceptor; public class MainServer { private int PORT = 5600; public MainServer() { NioDatagramAcceptor acceptor = new NioDatagramAcceptor(); acceptor.setHandler(new UdpServerHandler()); Executor threadPool = Executors.newCachedThreadPool(); DefaultIoFilterChainBuilder chain = acceptor.getFilterChain(); // chain.addLast("logger", new LoggingFilter()); // chain.addLast("codec", new ProtocolCodecFilter( // new TextLineCodecFactory(Charset.forName("UTF-8")))); // chain.addLast("codec", new ProtocolCodecFilter( // new ObjectSerializationCodecFactory())); chain.addLast("threadPool", new ExecutorFilter(threadPool)); DatagramSessionConfig dcfg = acceptor.getSessionConfig(); dcfg.setReadBufferSize(4096);// 设置接收最大字节默认2048 dcfg.setMaxReadBufferSize(65536); dcfg.setReceiveBufferSize(1024);// 设置输入缓冲区的大小 dcfg.setSendBufferSize(1024);// 设置输出缓冲区的大小 dcfg.setReuseAddress(true);// 设置每一个非主监听连接的端口可以重用 try { acceptor.bind(new InetSocketAddress(PORT)); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println("UDPServer listening on port " + PORT); } /** * @param args */ public static void main(String[] args) { // TODO Auto-generated method stub new MainServer(); } }