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.MultiThreadIoEventLoopGroup;
23 import io.netty.channel.nio.NioIoHandler;
24 import io.netty.channel.sctp.SctpChannel;
25 import io.netty.channel.sctp.SctpChannelOption;
26 import io.netty.channel.sctp.nio.NioSctpChannel;
27
28 /**
29 * Sends one message when a connection is open and echoes back any received
30 * data to the server over SCTP connection.
31 *
32 * Simply put, the echo client initiates the ping-pong
33 * traffic between the echo client and server by sending the first message to
34 * the server.
35 */
36 public final class SctpEchoClient {
37
38 static final String HOST = System.getProperty("host", "127.0.0.1");
39 static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
40 static final int SIZE = Integer.parseInt(System.getProperty("size", "256"));
41
42 public static void main(String[] args) throws Exception {
43 // Configure the client.
44 EventLoopGroup group = new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory());
45 try {
46 Bootstrap b = new Bootstrap();
47 b.group(group)
48 .channel(NioSctpChannel.class)
49 .option(SctpChannelOption.SCTP_NODELAY, true)
50 .handler(new ChannelInitializer<SctpChannel>() {
51 @Override
52 public void initChannel(SctpChannel ch) throws Exception {
53 ch.pipeline().addLast(
54 //new LoggingHandler(LogLevel.INFO),
55 new SctpEchoClientHandler());
56 }
57 });
58
59 // Start the client.
60 ChannelFuture f = b.connect(HOST, PORT).sync();
61
62 // Wait until the connection is closed.
63 f.channel().closeFuture().sync();
64 } finally {
65 // Shut down the event loop to terminate all threads.
66 group.shutdownGracefully();
67 }
68 }
69 }