CrusherDatagramSocat4Test.java 文件源码

@Before
public void setUp() throws Exception {
    reactor = new NioReactor();

    crusher = DatagramCrusherBuilder.builder()
        .withReactor(reactor)
        .withBindAddress(ADDR_LOOPBACK4, PORT_DIRECT)
        .withConnectAddress(ADDR_LOOPBACK4, PORT_PROXY)
        .withProtocolFamily(StandardProtocolFamily.INET)
        .withCreationListener((addr) -> LOGGER.info("Client is created <{}>", addr))
        .withDeletionListener((addr, byteMeters, packetMeters) -> LOGGER.info("Client is deleted <{}>", addr))
        .buildAndOpen();
}