나는 HTTP 요청/응답을 처리하기 위해 Netty를 사용하고있다. 그리고 파이프 라인 아래로 다음 ByteBuf 작성 : 로그에서 public class MyBusinessLogic
extends ChannelInboundHandlerAdapter{
public void channelRead(ChannelHandlerContext ctx, Ob
그래서 저는 netty가있는 서버를 작성해 왔으며 다른 것을 작성하지 않았으므로 파이프 라인에 대한 내 접근 방식이 올바른지 궁금합니다. 나는 서버 및 클라이언트, ObjectEncoder 및 디코더에 2 개의 기본 처리기가 있으며, 예를 들어 UserAuthenticationHandler, UserActionHandler가 있고 각기 다른 패킷 및 패스를
다음과 같은 설정이 있습니다. APPID (연결된 클라이언트 당)라는 고유 식별자를 기반으로 메시지 큐 (내 경우에는 LinkedBlockingQueues)의 구성 걸쳐 인바운드 클라이언트의 메시지를 확산하는 메시지 유통 업체가있다 : 나는 또한 답변을 필요로하는 public class MessageDistributor {
private fina
를 사용하여 이미지를 수신 : 는 public class Send {
public static void main(String[] args) throws Exception {
Socket socket = new Socket(serverIP, serverPORT);
OutputStream outputStream = socket.
나는 시계를 사용하고 사용자 정의 IoT 논리를 구현합니다. 나는 netty를 사용하여 시계에서 연결을 받고 일부 데이터를 저장하고 그 접근법으로 잘 작동하고있다. 그러나 나는 새로운 지켜야 할 명령을 보내야한다. 그것을하기 위해 나는 Netty에서 이미 열린 채널에 명령을 보낼 수 있지만 그 접근법으로 나는 imei으로지도를 저장하고 netty 채널을 열
파일을 보낼 때 ctx.writeAndFlush(new ChunkedFile(new File("file.png")));을 사용할 수 있습니다. 어때 약 List<Object>? 목록에 String 및 bytes of image이 포함되어 있습니다. 설명서에는 ChunkedInput()이 있지만 사용법을 알 수는 없습니다. UPDATE 은 내가 수행 한 Li
Netty을 사용하여 서버에 연결된 Java TCP 클라이언트가 있습니다. 연결이 끊어진 채널을 작성하면 예외가 발생합니다. 어떤 문제가이 문제의 원인인지는 중요하지 않지만 어떤 메시지가 이 아니고으로 전송되지 않았고 예외가 발생한 것이 중요합니다. [ChannelPromise 또는 ChannelFuture를 사용하여 어떻게 찾을 수 있습니까?] 여기에 '
내 서버 Netty 기반 응용 프로그램에서 Oio를 사용하려고합니다. 현재 다음과 같이 사용하고 있습니다 : String host: String = //...
int port = //...
ServerBootstrap server = new ServerBootstrap()
.group(new OioEventLoopGroup(), new Oio
I은 문제가 있다면, 나는 인 Netty 여러 클라이언트와 백 엔드 서버가 백 엔드에서 백엔드 거래 데이터 은행 및 제어 시스템 등 모든 데이터와 행위, BSON 문서로 구성된 플레이어가 있습니다. 이제 클라이언트 중 하나에서이 작업을 수행하고 백엔드에 다시로드하고 싶습니다. 어떻게 백엔드가 데이터에 쓰는 동안 클라이언트가 데이터를 편집하고 저장하지 못