1 /*
2 * Copyright 2012 The Netty Project
3 *
4 * The Netty Project licenses this file to you under the Apache License,
5 * version 2.0 (the "License"); you may not use this file except in compliance
6 * with the License. You may obtain a copy of the License at:
7 *
8 * https://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
12 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
13 * License for the specific language governing permissions and limitations
14 * under the License.
15 */
16 package io.netty.example.sctp;
17
18 import io.netty.bootstrap.Bootstrap;
19 import io.netty.channel.ChannelFuture;
20 import io.netty.channel.ChannelInitializer;
21 import io.netty.channel.EventLoopGroup;
22 import io.netty.channel.nio.NioEventLoopGroup;
23 import io.netty.channel.sctp.SctpChannel;
24 import io.netty.channel.sctp.SctpChannelOption;
25 import io.netty.channel.sctp.nio.NioSctpChannel;
26
27 /**
28 * Sends one message when a connection is open and echoes back any received
29 * data to the server over SCTP connection.
30 *
31 * Simply put, the echo client initiates the ping-pong
32 * traffic between the echo client and server by sending the first message to
33 * the server.
34 */
35 public final class SctpEchoClient {
36
37 static final String HOST = System.getProperty("host", "127.0.0.1");
38 static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
39 static final int SIZE = Integer.parseInt(System.getProperty("size", "256"));
40
41 public static void main(String[] args) throws Exception {
42 // Configure the client.
43 EventLoopGroup group = new NioEventLoopGroup();
44 try {
45 Bootstrap b = new Bootstrap();
46 b.group(group)
47 .channel(NioSctpChannel.class)
48 .option(SctpChannelOption.SCTP_NODELAY, true)
49 .handler(new ChannelInitializer<SctpChannel>() {
50 @Override
51 public void initChannel(SctpChannel ch) throws Exception {
52 ch.pipeline().addLast(
53 //new LoggingHandler(LogLevel.INFO),
54 new SctpEchoClientHandler());
55 }
56 });
57
58 // Start the client.
59 ChannelFuture f = b.connect(HOST, PORT).sync();
60
61 // Wait until the connection is closed.
62 f.channel().closeFuture().sync();
63 } finally {
64 // Shut down the event loop to terminate all threads.
65 group.shutdownGracefully();
66 }
67 }
68 }