下面列出了io.netty.channel.sctp.nio.NioSctpChannel#io.netty.channel.sctp.SctpChannelOption 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。
public static void main(String[] args) throws Exception {
EventLoopGroup loopGroup = new NioEventLoopGroup();
try {
ChannelFuture f = new Bootstrap().group(loopGroup)
.channel(NioSctpChannel.class)
// set SCTP option
.option(SctpChannelOption.SCTP_NODELAY, true)
.handler(new ChannelInitializer<SctpChannel>() {
@Override
public void initChannel(SctpChannel ch) throws Exception {
ChannelPipeline p = ch.pipeline();
p.addLast(new SimpleSctpClientHandler());
}
}).connect(HOST, PORT).sync();
f.channel().closeFuture().sync();
} finally {
loopGroup.shutdownGracefully();
}
}
public static void main(String[] args) throws Exception {
EventLoopGroup loopGroup = new NioEventLoopGroup();
try {
ChannelFuture f = new Bootstrap().group(loopGroup)
.channel(NioSctpChannel.class)
// set SCTP option
.option(SctpChannelOption.SCTP_NODELAY, true)
.handler(new ChannelInitializer<SctpChannel>() {
@Override
public void initChannel(SctpChannel ch) throws Exception {
ChannelPipeline p = ch.pipeline();
p.addLast(new SimpleSctpClientHandler());
}
}).connect(HOST, PORT).sync();
f.channel().closeFuture().sync();
} finally {
loopGroup.shutdownGracefully();
}
}
public static void main(String[] args) throws Exception {
// Configure the client.
EventLoopGroup group = new NioEventLoopGroup();
try {
Bootstrap b = new Bootstrap();
b.group(group)
.channel(NioSctpChannel.class)
.option(SctpChannelOption.SCTP_NODELAY, true)
.handler(new ChannelInitializer<SctpChannel>() {
@Override
public void initChannel(SctpChannel ch) throws Exception {
ch.pipeline().addLast(
//new LoggingHandler(LogLevel.INFO),
new SctpEchoClientHandler());
}
});
// Start the client.
ChannelFuture f = b.connect(HOST, PORT).sync();
// Wait until the connection is closed.
f.channel().closeFuture().sync();
} finally {
// Shut down the event loop to terminate all threads.
group.shutdownGracefully();
}
}
public static void main(String[] args) throws Exception {
// Configure the client.
EventLoopGroup group = new NioEventLoopGroup();
try {
Bootstrap b = new Bootstrap();
b.group(group)
.channel(NioSctpChannel.class)
.option(SctpChannelOption.SCTP_NODELAY, true)
.handler(new ChannelInitializer<SctpChannel>() {
@Override
public void initChannel(SctpChannel ch) throws Exception {
ch.pipeline().addLast(
//new LoggingHandler(LogLevel.INFO),
new SctpEchoClientHandler());
}
});
// Start the client.
ChannelFuture f = b.connect(HOST, PORT).sync();
// Wait until the connection is closed.
f.channel().closeFuture().sync();
} finally {
// Shut down the event loop to terminate all threads.
group.shutdownGracefully();
}
}
private void applySctpOptions(ServerBootstrap b) {
b.childOption(SctpChannelOption.SCTP_NODELAY, this.management.getOptionSctpNodelay());
b.childOption(SctpChannelOption.SCTP_DISABLE_FRAGMENTS, this.management.getOptionSctpDisableFragments());
b.childOption(SctpChannelOption.SCTP_FRAGMENT_INTERLEAVE, this.management.getOptionSctpFragmentInterleave());
b.childOption(SctpChannelOption.SCTP_INIT_MAXSTREAMS, this.management.getOptionSctpInitMaxstreams());
b.childOption(SctpChannelOption.SO_SNDBUF, this.management.getOptionSoSndbuf());
b.childOption(SctpChannelOption.SO_RCVBUF, this.management.getOptionSoRcvbuf());
b.childOption(SctpChannelOption.SO_LINGER, this.management.getOptionSoLinger());
}
private void applySctpOptions(Bootstrap b) {
b.option(SctpChannelOption.SCTP_NODELAY, this.management.getOptionSctpNodelay());
b.option(SctpChannelOption.SCTP_DISABLE_FRAGMENTS, this.management.getOptionSctpDisableFragments());
b.option(SctpChannelOption.SCTP_FRAGMENT_INTERLEAVE, this.management.getOptionSctpFragmentInterleave());
b.option(SctpChannelOption.SCTP_INIT_MAXSTREAMS, this.management.getOptionSctpInitMaxstreams());
b.option(SctpChannelOption.SO_SNDBUF, this.management.getOptionSoSndbuf());
b.option(SctpChannelOption.SO_RCVBUF, this.management.getOptionSoRcvbuf());
b.option(SctpChannelOption.SO_LINGER, this.management.getOptionSoLinger());
}