查看本类的 API文档回源码主页即时通讯网 - 即时通讯开发者社区!
1   /*
2    * Copyright 2014 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.stomp;
17  
18  import io.netty.bootstrap.Bootstrap;
19  import io.netty.channel.ChannelInitializer;
20  import io.netty.channel.ChannelPipeline;
21  import io.netty.channel.EventLoopGroup;
22  import io.netty.channel.nio.NioEventLoopGroup;
23  import io.netty.channel.socket.SocketChannel;
24  import io.netty.channel.socket.nio.NioSocketChannel;
25  import io.netty.handler.codec.stomp.StompSubframeAggregator;
26  import io.netty.handler.codec.stomp.StompSubframeDecoder;
27  import io.netty.handler.codec.stomp.StompSubframeEncoder;
28  
29  
30  /**
31   * very simple stomp client implementation example, requires running stomp server to actually work
32   * uses default username/password and destination values from hornetq message broker
33   */
34  public final class StompClient {
35  
36      static final boolean SSL = System.getProperty("ssl") != null;
37      static final String HOST = System.getProperty("host", "127.0.0.1");
38      static final int PORT = Integer.parseInt(System.getProperty("port", "61613"));
39      static final String LOGIN = System.getProperty("login", "guest");
40      static final String PASSCODE = System.getProperty("passcode", "guest");
41      static final String TOPIC = System.getProperty("topic", "jms.topic.exampleTopic");
42  
43      public static void main(String[] args) throws Exception {
44          EventLoopGroup group = new NioEventLoopGroup();
45          try {
46              Bootstrap b = new Bootstrap();
47              b.group(group).channel(NioSocketChannel.class);
48              b.handler(new ChannelInitializer<SocketChannel>() {
49                  @Override
50                  protected void initChannel(SocketChannel ch) throws Exception {
51                      ChannelPipeline pipeline = ch.pipeline();
52                      pipeline.addLast("decoder", new StompSubframeDecoder());
53                      pipeline.addLast("encoder", new StompSubframeEncoder());
54                      pipeline.addLast("aggregator", new StompSubframeAggregator(1048576));
55                      pipeline.addLast("handler", new StompClientHandler());
56                  }
57              });
58  
59              b.connect(HOST, PORT).sync().channel().closeFuture().sync();
60          } finally {
61              group.shutdownGracefully();
62          }
63      }
64  }