1

私は Netty を初めて使いましたが、4.0.0 から始めることにしました。これは、より新しいため、より優れているはずだと考えたからです。私のサーバー アプリケーションは gps デバイスからデータを受信する必要があり、プロセスは次のようになります。デバイスからデータを受け取りたい場合。応答後、デバイスから AVL プロトコルで GPS データが送信されます。現在、私のサーバーは Netty なしで動作しており、netty で動作するように変更したいと考えています。これは私がやったことです：

このようなサーバークラスを作成しました

public class BusDataReceiverServer {

private final int port;
private final Logger LOG = LoggerFactory.getLogger(BusDataReceiverServer.class);

public BusDataReceiverServer(int port) {
    this.port = port;
}

public void run() throws Exception {
    LOG.info("running thread");
    EventLoopGroup bossGroup = new NioEventLoopGroup();
    EventLoopGroup workerGroup = new NioEventLoopGroup();
    try{
        ServerBootstrap b = new ServerBootstrap();
        b.group(bossGroup, workerGroup)
                .channel(NioServerSocketChannel.class)
                .childHandler(new BusDataReceiverInitializer());
        b.bind(port).sync().channel().closeFuture().sync();
    }catch (Exception ex){
        LOG.info(ex.getMessage());
    }
    finally {
        LOG.info("thread closed");
        bossGroup.shutdownGracefully();
        workerGroup.shutdownGracefully();
    }
}

public static void main(String[] args) throws Exception {
    new BusDataReceiverServer(3129).run();
}

}

そして作成された初期化クラス

public class BusDataReceiverInitializer extends ChannelInitializer<SocketChannel> {

    @Override
    protected void initChannel(SocketChannel socketChannel) throws Exception {
        ChannelPipeline pipeline = socketChannel.pipeline();

        pipeline.addLast("imeiDecoder", new ImeiDecoder());
        pipeline.addLast("busDataDecoder", new BusDataDecoder());
        pipeline.addLast("encoder", new ResponceEncoder());

        pipeline.addLast("imeiHandler", new ImeiReceiverServerHandler());
        pipeline.addLast("busDataHandler", new BusDataReceiverServerHandler());
    }
}

次に、デコーダーとエンコーダー、および 2 つのハンドラーを作成しました。私のimeiDecoderとエンコーダー、およびImeiReceiverServerHandlerは機能しています。これは私のImeiReceiverServerHandlerです

public class ImeiReceiverServerHandler extends ChannelInboundHandlerAdapter {

    private final Logger LOG = LoggerFactory.getLogger(ImeiReceiverServerHandler.class);

    @Override
    public void messageReceived(ChannelHandlerContext ctx, MessageList<Object> msgs) throws Exception {
        MessageList<String> imeis = msgs.cast();
        String imei = imeis.get(0);

        ctx.write(Constants.BUS_DATA_ACCEPT);
        ctx.fireMessageReceived(msgs);

    }

    @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        super.channelInactive(ctx);    //To change body of overridden methods use File | Settings | File Templates.
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        super.exceptionCaught(ctx, cause);    //To change body of overridden methods use File | Settings | File Templates.
    }
}

さて、受け入れた後、gpsデータを引き続き受信してハンドラーBusDataReceiverServerHandlerに転送する方法がわかりません。誰かがこれについて私を助けてくれたり、有用なドキュメントを提供してくれたりしたら、とても感謝しています。または、Netty 3 でこれを行うことができれば、これもありがたいです。

4

1 に答える 1

2

私は Netty 4 を使用したことがないので、私の回答が 100% 正確であるか、Netty 4 で行う最善の方法であるかはわかりませんが、接続/クライアント セッションの状態を追跡する必要があります。メッセージを 2 番目のハンドラーに転送するタイミングを把握します。

例えば

private enum HandlerState { INITIAL, IMEI_RECEIVED; }
private HandlerState state = HandlerState.INITIAL;

@Override
public void messageReceived(ChannelHandlerContext ctx, MessageList<Object> msgs) throws Exception
{

    if (state == HandlerState.INITIAL)
    {
        MessageList<String> imeis = msgs.cast();
        String imei = imeis.get(0);

        ctx.write(Constants.BUS_DATA_ACCEPT);
        state = HandlerState.IMEI_RECEIVED;
    } else
    {
        // Forward message to next handler...
        // Not sure exactly how this is done in Netty 4
        // Maybe: ctx.fireMessageReceived(msgs);
        // Or maybe it is:
        // ctx.nextInboundMessageBuffer().add(msg);
        // ctx.fireInboundBufferUpdated();

        // I believe you could also remove the IMEI handler from the
        // pipeline instead of having it keep state, if it is not going to do anything
        // further.
    }

}

したがって、ハンドラーで状態を追跡するか、それ以上使用されない場合は、ハンドラーが終了したらパイプラインからハンドラーを削除します。状態を追跡する場合、ハンドラー自体に状態を保持するか (上記のように)、コンテキスト/属性マップに状態変数を保持することができます (ただし、netty 4 ではこれが行われます)。

ハンドラー自体で状態を保持しない理由は、ハンドラーを共有可能にする (複数のチャネルで使用される 1 つのインスタンス) 場合です。これを行う必要はありませんが、多数の同時チャネルがある場合は、リソースが節約される可能性があります。

于 2013-07-03T22:09:49.047 に答える