Как использовать один Bootstrap для подключения к нескольким серверам в Netty

Я не знаю, есть ли проблема с производительностью, если я создаю (новую) загрузочную программу каждый раз, когда подключаюсь к удаленному серверу. Поэтому я хочу использовать один экземпляр начальной загрузки для подключения к нескольким серверам. Мой код ниже:

Bootstrap b = new Bootstrap();
b.group(new NioEventLoopGroup()).handler(new TestHandler()).channel(NioSocketChannel.class)
        .option(ChannelOption.AUTO_READ, false);
ChannelFutureListener listener = new ChannelFutureListener() {
    @Override
    public void operationComplete(ChannelFuture future) throws Exception {
        if (future.isSuccess()) {
            // connection complete start to read first data
            System.out.println("connection established + channel: " + future.channel());
        } else {
            // Close the connection if the connection attempt has failed.
            System.out.println("connection failed");
        }
    }
};

String[] urls = { "www.google.com", "www.stackoverflow.com", "www.yahoo.com" };
for (String s : urls) {
    b = b.clone();
    b.remoteAddress(s, 80);
    b.connect().addListener(listener);
}
System.in.read();

К сожалению, произошел сбой:

connection established + channel: [id: 0x5df86eec, /192.168.126.136:60414 => www.google.com/173.194.127.209:80]
Exception in thread "main" java.lang.IllegalStateException: channel not registered to an event loop
    at io.netty.channel.AbstractChannel.eventLoop(AbstractChannel.java:107)
    at io.netty.channel.nio.AbstractNioChannel.eventLoop(AbstractNioChannel.java:102)
    at io.netty.channel.nio.AbstractNioChannel.eventLoop(AbstractNioChannel.java:41)
    at io.netty.channel.CompleteChannelFuture.executor(CompleteChannelFuture.java:48)
    at io.netty.util.concurrent.CompleteFuture.addListener(CompleteFuture.java:49)
    at io.netty.channel.CompleteChannelFuture.addListener(CompleteChannelFuture.java:56)
    at Test3.main(Test3.java:41)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    at java.lang.reflect.Method.invoke(Method.java:597)
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:120)

Думаю, я неправильно использую бутстрап. Если да, должен ли я каждый раз создавать новый бутстрап?

По крайней мере, я должен использовать ту же группу NioEventLoopGroup, верно?


java netty
person Alexis    schedule 05.12.2013    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Хорошо, это моя вина, я забыл добавить ChannelInitializer. Измените его на код ниже:

b.group(new NioEventLoopGroup()).handler(new ChannelInitializer<NioSocketChannel>() {

            @Override
            protected void initChannel(NioSocketChannel ch) throws Exception {
                ch.pipeline().addLast(new TestHandler());
            }
        })
person Alexis    schedule 05.12.2013