11.4 结合在一起使用 

    一如既往，我们要将它们结合在一起使用。使用Bootstrap引导服务器和设置正确的ChannelInitializer。看下面代码：

[java] view plaincopy

  1. package netty.in.action;
  3. import io.netty.bootstrap.ServerBootstrap;
  4. import io.netty.channel.Channel;
  5. import io.netty.channel.ChannelFuture;
  6. import io.netty.channel.ChannelInitializer;
  7. import io.netty.channel.EventLoopGroup;
  8. import io.netty.channel.group.ChannelGroup;
  9. import io.netty.channel.group.DefaultChannelGroup;
  10. import io.netty.channel.nio.NioEventLoopGroup;
  11. import io.netty.channel.socket.nio.NioServerSocketChannel;
  12. import io.netty.util.concurrent.ImmediateEventExecutor;
  14. import java.net.InetSocketAddress;
  16. /**
    • @author c.k
  21. */
  22. public class ChatServer {
  24. private final ChannelGroup group = new DefaultChannelGroup(
  25. ImmediateEventExecutor.INSTANCE);
  26. private final EventLoopGroup workerGroup = new NioEventLoopGroup();
  27. private Channel channel;
  29. public ChannelFuture start(InetSocketAddress address) {
  30. ServerBootstrap b = new ServerBootstrap();
  31. b.group(workerGroup).channel(NioServerSocketChannel.class)
  32. .childHandler(createInitializer(group));
  33. ChannelFuture f = b.bind(address).syncUninterruptibly();
  34. channel = f.channel();
  35. return f;
  36. }
  38. public void destroy() {
  39. if (channel != null)
  40. channel.close();
  41. group.close();
  42. workerGroup.shutdownGracefully();
  43. }
  45. protected ChannelInitializer<Channel> createInitializer(ChannelGroup group) {
  46. return new ChatServerInitializer(group);
  47. }
  49. public static void main(String[] args) {
  50. final ChatServer server = new ChatServer();
  51. ChannelFuture f = server.start(new InetSocketAddress(2048));
  52. Runtime.getRuntime().addShutdownHook(new Thread() {
  53. @Override
  54. public void run() {
  55. server.destroy();
  56. }
  57. });
  58. f.channel().closeFuture().syncUninterruptibly();
  59. }
  61. }

另外，需要将index.html文件放在项目根目录，index.html内容如下：

[html] view plaincopy

  1. <html>
  2. <head>
  3. <title>Web Socket Test</title>
  4. </head>
  5. <body>
  6. <script type="text/javascript">
  7. var socket;
  8. if (!window.WebSocket) {
  9. window.WebSocket = window.MozWebSocket;
  10. }
  11. if (window.WebSocket) {
  12. socket = new WebSocket("ws://localhost:2048/ws");
  13. socket.onmessage = function(event) {
  14. var ta = document.getElementById('responseText');
  15. ta.value = ta.value + '\n' + event.data
  16. };
  17. socket.onopen = function(event) {
  18. var ta = document.getElementById('responseText');
  19. ta.value = "Web Socket opened!";
  20. };
  21. socket.onclose = function(event) {
  22. var ta = document.getElementById('responseText');
  23. ta.value = ta.value + "Web Socket closed";
  24. };
  25. } else {
  26. alert("Your browser does not support Web Socket.");
  27. }
  29. function send(message) {
  30. if (!window.WebSocket) { return; }
  31. if (socket.readyState == WebSocket.OPEN) {
  32. socket.send(message);
  33. } else {
  34. alert("The socket is not open.");
  35. }
  36. }
  37. </script>
  38. <form onsubmit="return false;">
  39. <input type="text" name="message" value="Hello, World!"><input
  40. type="button" value="Send Web Socket Data"
  41. onclick="send(this.form.message.value)">
  42. <h3>Output</h3>
  43. <textarea id="responseText" style="width: 500px; height: 300px;"></textarea>
  44. </form>
  45. </body>
  46. </html>

最后在浏览器中输入：http://localhost:2048，多开几个窗口就可以聊天了。

results matching ""

    No results matching ""