java - 错误: remoteAddress not set - jreactive-8583

Question

我们的服务器运行良好，下面是我们代码的非常基本的版本:

MessageFactory<IsoMessage> messageFactory = ConfigParser.createDefault();
Iso8583Client<IsoMessage> client = new Iso8583Client< (socketAddress,ClientConfiguration.getDefault(),messageFactory);
client.addMessageListener(new IsoMessageListener<IsoMessage>() {

        @Override
    public boolean applies(IsoMessage arg0) {

        return false;
    }

    @Override
    public boolean onMessage(ChannelHandlerContext arg0, IsoMessage arg1) {

        return false;
    }
});
client.getConfiguration().setReplyOnError(true);

client.init();
EventLoopGroup group = new NioEventLoopGroup();
try {
    client.connect("127.0.0.1", 8080);
} catch (InterruptedException e) {
    // TODO Auto-generated catch block
    System.out.println("Problem in client Connection");
    e.printStackTrace();
}

我收到以下错误，请帮忙:

线程“main”中出现异常 java.lang.IllegalStateException:remoteAddress 未设置在 io.netty.bootstrap.Bootstrap.connect(Bootstrap.java:116)在 com.github.kpavlov.jreactive8583.client.Iso8583Client.connectAsync(Iso8583Client.java:88)在 com.github.kpavlov.jreactive8583.client.Iso8583Client.connect(Iso8583Client.java:48)在 com.github.kpavlov.jreactive8583.client.Iso8583Client.connect(Iso8583Client.java:75)在 com.github.kpavlov.jreactive8583.client.Iso8583Client.connect(Iso8583Client.java:63)在 com.tushar.jreactive8583.demo_iso8385.AppClient.main(AppClient.java:62)

Answer 1

替换

Iso8583Client<IsoMessage> client = new Iso8583Client<>(messageFactory);

与

SocketAddress socketAddress = new InetSocketAddress("127.0.0.1", 8080);
Iso8583Client<IsoMessage> client = new Iso8583Client<>(socketAddress, messageFactory);