import org.apache.mina.transport.socket.DatagramSessionConfig; //导入依赖的package包/类
/***
 * Starts UDP listener and connector.
 */
private void setupNetwork() {
    // Setup server acceptor, since we need to be able to receive incoming packets from the provider
    acceptor = new NioDatagramAcceptor();
    acceptor.setHandler(this);
    DatagramSessionConfig dcfg = (DatagramSessionConfig) acceptor.getSessionConfig();
    dcfg.setReuseAddress(true);
    try {
        logger.info("Trying to listen to {}", this.port);
        acceptor.bind(new InetSocketAddress(this.port));
        logger.info("Listening on port {}", this.port);
    } catch (IOException e) {
        throw new RuntimeException(e);
    }

    // Setup client connector to provider
    connector = new NioDatagramConnector();
    connector.setHandler(this);
    logger.info("Connecting to {} ({}:{})", this.provider.name, this.provider.host, this.provider.port);
    session = connector.connect(new InetSocketAddress(this.provider.host, this.provider.port))
            .awaitUninterruptibly()
            .getSession();
}
 

import org.apache.mina.transport.socket.DatagramSessionConfig; //导入依赖的package包/类
private void init(Config config) {
    address = new InetSocketAddress(config.sourcePort);

    acceptor = new NioDatagramAcceptor();
    acceptor.setHandler(new MinaServerHandler());
    DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
    if (acceptor.getFilterChain().get(LOGGER) == null) {
        chain.addLast(LOGGER, new LoggingFilter());
    }
    if (acceptor.getFilterChain().get(CODEC) == null) {
        ProtocolCodecFactory codecFactory = config.codec == null ?
                MinaUtil.getTextLineCodecFactory() : (ProtocolCodecFactory) config.codec;
        chain.addLast(CODEC, new ProtocolCodecFilter(codecFactory));
    }
    DatagramSessionConfig dcfg = acceptor.getSessionConfig();
    dcfg.setReuseAddress(true);
    dcfg.setReadBufferSize(config.bufferSize);
    dcfg.setIdleTime(IdleStatus.WRITER_IDLE, 10);
    dcfg.setBroadcast(true);

    KeepAliveFilter keepAliveFilter = MinaUtil.initServerKeepAlive(config, this);
    if (keepAliveFilter != null) {
        acceptor.getFilterChain().addLast(HEARTBEAT, keepAliveFilter);
    }
}
 

import org.apache.mina.transport.socket.DatagramSessionConfig; //导入依赖的package包/类
private UDPServer(String host, int port) {
    this.host = host;
    this.port = port;
    acceptor = new NioDatagramAcceptor();
    DatagramSessionConfig sessionConfig = acceptor.getSessionConfig();
    sessionConfig.setReuseAddress(true);
    acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(codecFactory));
    acceptor.getFilterChain().addLast("logger", new LoggingFilter());
    acceptor.setHandler(this);

}
 

import org.apache.mina.transport.socket.DatagramSessionConfig; //导入依赖的package包/类
@Override
public void start() throws IOException {
    acceptor = new NioDatagramAcceptor();
    acceptor.setDefaultLocalAddress(new InetSocketAddress(getPort()));
    acceptor.getFilterChain().addLast("logger-data", new LoggingFilter("tftp-server-data"));
    acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TftpProtocolCodecFactory()));
    acceptor.getFilterChain().addLast("logger-packet", new LoggingFilter("tftp-server-packet"));
    acceptor.setHandler(new TftpServerProtocolHandler(getDataProvider()));
    DatagramSessionConfig dcfg = acceptor.getSessionConfig();
    dcfg.setReuseAddress(true);
    // dcfg.setIdleTime(IdleStatus.BOTH_IDLE, 5);
    acceptor.bind();
}
 

import org.apache.mina.transport.socket.DatagramSessionConfig; //导入依赖的package包/类
public static void main(String[] args) throws Exception {
	NioDatagramAcceptor acceptor = new NioDatagramAcceptor();//UDP Acceptor
	acceptor.getFilterChain().addLast("logging", new LoggingFilter());
	acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
	acceptor.getFilterChain().addLast("mdc", new MdcInjectionFilter());
	acceptor.setHandler(new HelloServerHandler());
	acceptor.getSessionConfig().setReadBufferSize(2048);
	acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
	DatagramSessionConfig dcfg = acceptor.getSessionConfig();
	dcfg.setReuseAddress(true);
	acceptor.bind(new InetSocketAddress(PORT));
}
 

import org.apache.mina.transport.socket.DatagramSessionConfig; //导入依赖的package包/类
@Override
public DatagramSessionConfig getSessionConfig() {
    return (DatagramSessionConfig) super.getSessionConfig();
}
 

import org.apache.mina.transport.socket.DatagramSessionConfig; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
public DatagramSessionConfig getConfig() {
    return (DatagramSessionConfig) config;
}
 

import org.apache.mina.transport.socket.DatagramSessionConfig; //导入依赖的package包/类
public PeerlessUdpServer(PeerlessDbSupport peerlessDbSupport, SigHashTable sht) throws IOException {
	
	this.sht=sht;
	this.peerlessDbSupport=peerlessDbSupport;

    NioDatagramAcceptor acceptor = new NioDatagramAcceptor();
    acceptor.setHandler(new PeerlessUdpServerHandler(this));

    DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
    chain.addLast("logger", new LoggingFilter());

    DatagramSessionConfig dcfg = acceptor.getSessionConfig();
    dcfg.setReuseAddress(true);

 chain.addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));        
    
     acceptor.bind(new InetSocketAddress(PORT));
    System.out.println("UDPServer listening on port " + PORT);
}