Máy khách Netty, cách nhận phản hồi từ yêu cầu được gửi tới máy chủ

Question

Tôi đang cố gắng ghép nối với một khách hàng Netty. Tôi cần phải gửi một yêu cầu đến một máy chủ (mà tôi không kiểm soát) và tôi đang mong đợi một phản ứng trở lại.

Tôi không chắc chắn cách nhận phản hồi.

Vì vậy, nếu tôi đã có:

ChannelFuture future = bootstrap.connect(new InetSocketAddress("foo.com", 1654)); 
Channel connector = future.awaitUninterruptibly().getChannel(); 
ChannelFuture response = connector.write(query); 

Làm thế nào để tôi nhận được các dữ liệu phản ứng ra của phản ứng ChannelFuture? Tôi có cần thêm ChannelHandler vào đường dẫn khởi động không? Nếu vậy, làm cách nào để tôi liên kết phản hồi với yêu cầu?

Xin cảm ơn,

Answer 1

Bạn cần thêm ChannelHandler. Cách đơn giản nhất trong trường hợp của bạn là mở rộng SimpleChannelUpstreamHandler và ghi đè phương thức channelConnected(…) và phương pháp messageReceived(…). Trong channelConnected bạn sẽ kích hoạt Channel.write(…) và trong messageReceived bạn nhận được phản hồi. Nếu các câu trả lời có thể đến theo thứ tự khác nhau thì ghi bạn cần phải viết mã xử lý của riêng bạn.

Một giải pháp khác là thêm SimpleChannelUpstreamHandler vào đường ống trước khi bạn gọi. Một cái gì đó như thế này:

channel.getPipeline().addLast("yourHandlerName", new SimpleChannelUpstreamHandler()) { 
    public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception { 
     // remove handler after receiving response 
     ctx.getPipeline().remove(this); 

     // do logic 
     ... 
     } 
}); 

Answer 2

Thứ nhất, bạn có thể tham khảo mẫu giờ địa phương. Trong trình xử lý "LocalTimeClientHandler", bạn có thể tìm thấy thủ thuật chặn yêu cầu/phản hồi.

Nhưng đây vẫn là một "hello world" dự án giới thiệu, vì vậy vẫn còn 2 vấn đề chúng ta cần phải xem xét:

1. Ý tưởng trong mẫu này là để gửi một lô một lần và lấy lại một phản ứng Một lần. Vì vậy, nó không phù hợp cho mô hình sản xuất để gửi liên tục bằng cách tái sử dụng cùng một kênh.

2. Nếu bạn muốn gửi yêu cầu và nhận lại phản hồi đúng càng sớm càng tốt với tải nặng, bạn cần phải cấu trúc lại hàng đợi nhiều hơn một chút nếu không hiệu suất thực sự kém.