Netty入门实例-时间服务器

2019-04-20 15:42|来源: 网路

本教程中实现的协议是TIME协议。 它与先前的示例不同,时间服务器只发送包含32位整数的消息,而不接收任何请求,并在消息发送后关闭连接。 在本示例中,您将学习如何构造和发送消息,以及在完成时关闭连接。

因为时间服务器将忽略任何接收到的数据,但是一旦建立连接就发送消息,所以我们不能使用channelRead()方法。而是覆盖channelActive()方法。 以下是代码的实现:

package cn.sxt.netty.time;

public class TimeServerHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void channelActive(final ChannelHandlerContext ctx) { // (1)
        final ByteBuf time = ctx.alloc().buffer(4); // (2)
        time.writeInt((int) (System.currentTimeMillis() / 1000L + 2208988800L));

        final ChannelFuture f = ctx.writeAndFlush(time); // (3)
        f.addListener(new ChannelFutureListener() {
            @Override
            public void operationComplete(ChannelFuture future) {
                assert f == future;
                ctx.close();
            }
        }); // (4)
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }}


下面我们来看看上面代码的一些解释分析:

  1. 如上所述,当建立连接并准备好生成流量时,将调用channelActive()方法。现在在这个方法中编写一个32位的整数来表示当前的时间。

  2. 要发送新消息,需要分配一个包含消息的新缓冲区。我们要写入一个32位整数,因此需要一个ByteBuf,其容量至少为4个字节。 通过ChannelHandlerContext.alloc()获取当前的ByteBufAllocator并分配一个新的缓冲区。

  3. 像之前一样,编写构造的消息。
    但是,在NIO中发送消息之前,我们是否曾调用java.nio.ByteBuffer.flip()? ByteBuf没有这样的方法,它只有两个指针; 一个用于读取操作,另一个用于写入操作。 当您向ByteBuf写入内容时,写入索引会增加,而读取器索引不会更改。读取器索引和写入器索引分别表示消息的开始和结束位置。
    相比之下,NIO缓冲区不提供一个干净的方式来确定消息内容开始和结束,而不用调用flip方法。当您忘记翻转缓冲区时,就将会遇到麻烦,因为不会发送任何或发送不正确的数据。但是这样的错误不会发生在Netty中,因为不同的操作类型我们有不同的指针。
    另一点要注意的是ChannelHandlerContext.write()(和writeAndFlush())方法返回一个ChannelFutureChannelFuture表示尚未发生的I/O操作。这意味着,任何请求的操作可能尚未执行,因为所有操作在Netty中是异步的。 例如,以下代码可能会在发送消息之前关闭连接:

    Channel ch = ...;
    ch.writeAndFlush(message);
    ch.close();
  4. 因此,需要在ChannelFuture完成后调用close()方法,该方法由write()方法返回,并在写入操作完成时通知其监听器。 请注意,close()也可能不会立即关闭连接,并返回一个ChannelFuture。

当写请求完成时,我们如何得到通知? 这就像向返回的ChannelFuture添加ChannelFutureListener一样简单。 在这里,我们创建了一个新的匿名ChannelFutureListener,当操作完成时关闭Channel

或者,可以使用预定义的侦听器来简化代码:

f.addListener(ChannelFutureListener.CLOSE);


要测试我们的时间服务器是否按预期工作,可以使用UNIX rdate命令:

$ rdate -o <port> -p <host>


其中<port>是在main()方法中指定的端口号,<host>通常是localhost或服务器的IP地址。

编写时间客户端

DISCARDECHO服务器不同,我们需要一个用于TIME协议的客户端,因为我们无法将32位二进制数据转换为日历上的日期。 在本节中,我们讨论如何确保服务器正常工作并学习如何使用Netty编写客户端。

Netty中服务器和客户端之间最大的和唯一的区别是使用了不同的BootstrapChannel实现。 请看看下面的代码:

package cn.sxt.netty.time;

public class TimeClient {
    public static void main(String[] args) throws Exception {
        String host = args[0];
        int port = Integer.parseInt(args[1]);
        EventLoopGroup workerGroup = new NioEventLoopGroup();

        try {
            Bootstrap b = new Bootstrap(); // (1)
            b.group(workerGroup); // (2)
            b.channel(NioSocketChannel.class); // (3)
            b.option(ChannelOption.SO_KEEPALIVE, true); // (4)
            b.handler(new ChannelInitializer<SocketChannel>() {
                @Override
                public void initChannel(SocketChannel ch) throws Exception {
                    ch.pipeline().addLast(new TimeClientHandler());
                }
            });

            // Start the client.
            ChannelFuture f = b.connect(host, port).sync(); // (5)

            // Wait until the connection is closed.
            f.channel().closeFuture().sync();
        } finally {
            workerGroup.shutdownGracefully();
        }
    }
}


  1. BootstrapServerBootstrap类似,只是它用于非服务器通道,例如客户端或无连接通道。

  2. 如果只指定一个EventLoopGroup,它将同时用作boss组和worker组。boss组和worker组不是用于客户端。

  3. 不使用NioServerSocketChannel,而是使用NioSocketChannel来创建客户端通道。

  4. 注意,这里不像我们使用的ServerBootstrap,所以不使用childOption(),因为客户端SocketChannel没有父类。

  5. 应该调用connect()方法,而不是bind()方法。

如上面所见,它与服务器端代码没有什么不同。 ChannelHandler实现又是怎么样的呢? 它应该从服务器接收一个32位整数,将其转换为人类可读的格式,打印转换为我们熟知的时间格式 ,并关闭连接:

package cn.sxt.netty.time;

import java.util.Date;

public class TimeClientHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
                ByteBuf m = (ByteBuf) msg; // (1)
        try {
            long currentTimeMillis = (m.readUnsignedInt() - 2208988800L) * 1000L;
            Date currentTime = new Date(currentTimeMillis);
            System.out.println("Default Date Format:" + currentTime.toString());

            SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            String dateString = formatter.format(currentTime);
            // 转换一下成中国人的时间格式
            System.out.println("Date Format:" + dateString);

            ctx.close();
        } finally {
            m.release();
        }
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }
}


(1). 在TCP/IP中,Netty读取从对端发送的ByteBuf数据。

客户端看起来很简单,与服务器端示例没什么区别。 但是,这个处理程序有时会拒绝抛出IndexOutOfBoundsException。 我们将在下一节讨论为什么会发生这种情况。

先运行 TimeServer.java 程序,然后再运行 TimeClient.java , 当运行 TimeClient.java时就可以到有一个时间日期输出,然后程序自动退出。输出结果如下 -

Default Date Format:Thu Mar 02 20:50:23 CST 2017
Date Format:2017-03-02 20:50:23



相关问答

更多

netty4 服务器 创建后,使用端口 和ip进行 检测

1:请检查服务器是否开启了并且内网电脑能成功访问 2:检查路由器的端口映射的配置是否正确 3:查看自己电脑对应的服务和端口有没甫紶颠咳郯纠奠穴订膜有打开! 4:请检查您是否映射了服务器所需的所有端口,有可能没有完全设置访问服务器所需的端口,导致访问失败。您可以通过开启“DMZ主机”来检测一下,是否端口没有映射完全。若开启DMZ主机后,能正常访问服务器,则可能是端口添加不完全。 5:检查内网服务器端口是否和远程管理的端口冲突 6:服务商可能将相应端口屏蔽导致虚拟服务器无法访问,尝试修改服务端口!

使用netty服务器做通讯,服务端如何主动的向指定的客户端发送数据,求一个例子 谢谢 例如:有100个客户端

这和netty没啥关系吧,服务器端不能主动和客户端建立连接,除非客户端在监听,并且服务器端知道客户端IP和端口

从Netty Handler内部访问Netty服务器的实例(Accessing an instance of Netty server from inside a Netty Handler)

如果您有多个eventLoop,那么您将跨多个eventLoops同时访问静态ArrayList。 所以,你应该注意同步对ArrayList的访问。 If you have more than one eventLoop you are going to have concurrent access to the static ArrayList across multiple eventLoops. So YES you should take care of synchronizing the ...

Netty websocket服务器高可用性(Netty websocket server high availability)

因为Web套接字是面向连接的,所以如果您的服务器运行,那么您的Web套接字连接也是如此。 因此,为了实现高可用性,我认为您需要调整javascript代码以捕获连接错误并重新连接/登录。 通过这种方式,您可以将多个netty服务器放在负载均衡器后面。 希望这可以帮助。 Because web sockets is connection oriented, if your server goes does, so does your web socket connection. So, for hi ...

接收channelIdle超过预期(Netty套接字服务器)(Receiving channelIdle more than expected (Netty Socket Server))

看来问题是由于ISP错误而发生的。 谢谢。 It appears that problem was occurring due ISP errors. Thanks.

为什么netty http2服务器总是使用奇数来表示streamId(Why netty http2 server always use odd number for streamId)

流编号由HTTP / 2规范强制规定。 Stream numbering is mandated by the HTTP/2 specification.

Netty - UDP服务器(Netty - UDP server)

当使用UDP(数据报)通道作为服务器通道时,只能将其绑定在本地地址上,并且不会建立连接。 这就是为什么没有与该通道关联的远程地址,并且在调用MessageEvent.getChannel().getRemoteAddress()时总是得到null 。 这种行为是预期的并且是正确的 同一个UDP“服务器”通道处理所有传入的客户端请求。 当使用UDP通道作为客户端通道时,可以通过将通道连接到远程地址来创建“连接”。 在这种情况下,通道将有一个配置的远程地址(尽管没有实际连接)并调用MessageEve ...

Netty TCP推/流服务器(Netty TCP push/streaming server)

Nat回答了我的问题 - 在channelActive和channelInactive中添加和删除发送方通道组中的传入通道允许将任意结构的消息推送到订阅客户端。 Nat answered my question - adding and removing the incoming channel from the sender's channelgroup in channelActive and channelInactive allows messages of arbitrary struc ...

Netty将httprequest添加到服务器处理(Netty add httprequest to server handling)

请参阅netty示例,其中包含您需要的所有内容: https : //github.com/netty/netty/tree/4.1/example/src/main/java/io/netty/example/http/snoop Please see the netty examples which has everything you need: https://github.com/netty/netty/tree/4.1/example/src/main/java/io/netty/ex ...

如何在Netty服务器中部署Web应用程序(How to deploy a web application in Netty server)

Netty不是Web服务器/应用程序服务器,而是可用于构建Web服务器或任何高性能IO应用程序的IO框架。 如果你真的想使用netty,你需要自己编写一个HTTP服务器,或者只使用基于netty构建的HTTP框架。 如果您想使用netty构建应用程序,请查看https://github.com/netty/netty/tree/4.1/example/src/main/java/io/netty/example/上的示例。 Netty is not a web server/application ...