TCP

NioReactorreactor =newNioReactor();TcpCrushercrusher =TcpCrusherBuilder.builder()    .withReactor(reactor)    .withBindAddress("localhost",10080)    .withConnectAddress("google.com",80)    .buildAndOpen();// ... some actions// emulate reconnectcrusher.reopen();// ... check the client connection is reestablished successfully// closingcrusher.close();reactor.close();

UDP

NioReactorreactor =newNioReactor();DatagramCrushercrusher =DatagramCrusherBuilder.builder()    .withReactor(reactor)    .withBindAddress("localhost",10188)    .withConnectAddress("time-nw.nist.gov",37)    .buildAndOpen();// ... some actions// check data is sentAssert.assertTrue(crusher.getInner().getReadDatagramMeter().getTotal() >0);// closingcrusher.close();reactor.close();

Additional samples

Command line

$ ./run-tcp-crusher.sh 127.0.0.1:12345 google.com:80# Version: 0.8# Print `HELP` for the list of the commands# enter the command in the next lineCLOSE[20:19:20.586] INFO  TcpCrusher </127.0.0.1:12345>-<google.com/64.233.161.101:80> is closed[20:19:20.586] INFO  Crusher is closed# enter the command in the next lineOPEN[20:19:21.655] INFO  TcpCrusher </127.0.0.1:12345>-<google.com/64.233.161.101:80> is open[20:19:21.655] INFO  Crusher is open

Maven

<dependency>    <groupId>com.github.netcrusherorg</groupId>    <artifactId>netcrusher-core</artifactId>    <version>0.10</version></dependency>

Performance

License

Links to the similar projects