Netty Http Client: как разделить запуск клиента, отправку запроса и выключение клиента на разные методы - PullRequest
Новая
       6

Netty Http Client: как разделить запуск клиента, отправку запроса и выключение клиента на разные методы

0 голосов
/ 15 февраля 2019

1.Backgroud
Я обнаружил, что большинство примеров http-клиентов, использующих Netty, похоже, следуют этой структуре кода: 

public void run() {
    EventLoopGroup group = new NioEventLoopGroup();
    try {
        Bootstrap b = new Bootstrap();
        b.group(group)
         .channel(NioSocketChannel.class)
         .handler(new HttpSnoopClientInitializer(sslCtx));

        // Make the connection attempt.
        Channel ch = b.connect(host, port).sync().channel();
        // send something
        ch.writeAndFlush(XXXX);
        // Wait for the server to close the connection.
        ch.closeFuture().sync();
    } finally {
        // Shut down executor threads to exit.
        group.shutdownGracefully();
    }
}

Так что, если я правильно понимаю, каждый раз, когда я отправляю запрос, мне нужносоздать клиента и вызвать на нем client.run().Тем не менее, кажется, что я могу сделать только один «фиксированный» запрос за один раз.

2.Мне нужно
Мне нужен давний клиент, который может отправлять несколько запросов.Более конкретно, будет другой поток, отправляющий инструкцию клиенту, и каждый раз, когда клиент получает инструкцию, он отправляет запрос.Примерно так: 

Client client = new Client();
client.start();

client.sendRequest(request1);
client.sendRequest(request2);
...
client.shutDownGracefully(); // not sure if this shutdown is necessary or not
// because I need a long-standing client to wait for instructions to send requests
// in this sense it's kinda like a server.

3.Что я пробовал
Я пробовал что-то вроде этого: по этой ссылке 

public MyClient(String host, int port) {
    System.out.println("Initializing client and connecting to server..");
    EventLoopGroup workerGroup = new NioEventLoopGroup();

    Bootstrap b = new Bootstrap();
    b.group(workerGroup)
        .channel(NioSocketChannel.class)
        .option(ChannelOption.SO_KEEPALIVE, true)
        .handler(new ChannelInitializer<SocketChannel>() {
            @Override
            protected void initChannel(SocketChannel channel) throws Exception {
                channel.pipeline().addLast(new StringDecoder());
                channel.pipeline().addLast(new StringEncoder());
                channel.pipeline().addLast(new MyAppClientHandler());
            }
        });

    channelFuture = b.connect(host, port);
}

public ResponseFuture send(final String msg) {
    final ResponseFuture responseFuture = new ResponseFuture();

    channelFuture.addListener(new GenericFutureListener<ChannelFuture>() {
        @Override
        public void operationComplete(ChannelFuture future)
                throws Exception {
            channelFuture.channel().pipeline().get(MyAppClientHandler.class).setResponseFuture(responseFuture);
            channelFuture.channel().writeAndFlush(msg);                             
        }
    });

    return responseFuture;
}

public void close() {
    channelFuture.channel().close();        
}

Проблема в том, что кажется, что этот код не вызывал workerGroup.shutDownGracefully(), поэтому я предполагаю, что это может иметь проблемы.Есть ли способ разделить «запуск клиента», «отправить запрос», «завершение работы клиента» на отдельные методы?Заранее спасибо!

1 Ответ

0 голосов
/ 20 мая 2019

Самым простым решением будет использование ChannelPool, предоставляемого netty: https://netty.io/news/2015/05/07/4-0-28-Final.html

Он обеспечивает gracefulshutdown, maxconnections и т. Д. "Из коробки".

...