Я хочу отправить более одного ответа на client на основе внутреннего процесса. Но в Netty примерах я видел, что echo server одновременно отправляет обратно response.
Мое требование: мне нужно проверить клиента и отправить ему ответ OK, а затем отправить ему обновления DB, когда они будут доступны.
Как я могу отправить больше responses client? Пожалуйста, направьте меня к примеру или любому руководству?
в каждой точке конвейера вы можете получить конвейер Объект Channel из MessageEvent (или ChannelEvent) который передается от обработчика к обработчику. вы можете использовать эту информацию для отправки нескольких ответов в разные точки конвейера.
если мы возьмем пример эхо-сервера в качестве основы, мы можем добавить обработчик, который снова отправляет эхо (это можно сделать и в том же обработчике, но пример должен показать, что несколько обработчиков могут отвечать).
public class EchoServerHandler extends ChannelHandlerAdapter {
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
Channel ch = e.getChannel();
// first message
ch.write(e.getMessage());
}
// ...
}
public class EchoServerHandler2 extends ChannelHandlerAdapter {
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
Channel ch = e.getChannel();
// send second message
ch.write(e.getMessage());
}
// ...
}
Вы можете сделать это, если у вас есть ссылка на соответствующий Channel (или ChannelHandlerContext). Например, вы можете сделать это:
public class MyHandler extends ChannelHandlerAdapter {
...
public void channelRead(ctx, msg) {
MyRequest req = (MyRequest) msg;
ctx.write(new MyFirstResponse(..));
executor.execute(new Runnable() {
public void run() {
// Perform database operation
..
ctx.write(new MySecondResponse(...));
}
}
}
...
}
Вы можете делать это до тех пор, пока Нетти не закроет канал. Когда закончите, вам лучше вызвать close() самостоятельно.
Вот пример: https://stackoverflow.com/a/48128514/2557517
