PHP에서 Netty4 함수를 사용하는 방법

sudo pecl install netty

readString(); // 处理业务逻辑 // ... // 响应消息 $response = 'Hello, ' . $data . '!'; $ctx->write($response); } }

host = $host; $this->port = $port; $this->bossGroup = new EventLoopGroup(1); $this->workerGroup = new EventLoopGroup(4); $this->bootstrap = new ServerBootstrap(); $this->bootstrap->group($this->bossGroup, $this->workerGroup) ->channel(ServerSocketChannel::class) ->childHandler(new ServerHandler()); } public function run() { $channel = $this->bootstrap->bind(new SocketAddress($this->host, $this->port)); $channel->closeFuture()->sync(); $this->bossGroup->shutdownGracefully(); $this->workerGroup->shutdownGracefully(); } }

run();

response = $byteBuf->readString(); // 关闭连接 $ctx->close(); } public function getResponse() { return $this->response; } }

host = $host; $this->port = $port; $loopGroup = new EventLoopGroup(1); $handler = new ClientHandler(); $this->bootstrap = new Bootstrap(); $this->bootstrap->group($loopGroup) ->channel(ClientSocketChannel::class) ->option(ChannelOption::SO_KEEPALIVE, true) ->handler($handler); $this->group = $loopGroup; } public function connect($message) { $channel = $this->bootstrap->connect(new InetSocketAddress($this->host, $this->port))->sync(); $channel->write($message)->addListener(function($future) use($channel, $handler) { if ($future->isSuccess()) { echo "Send message success. "; } else { echo "Send message failed. "; } }); $channel->closeFuture()->sync(); $this->group->shutdownGracefully(); return $handler->getResponse(); } }

connect('Jack'); echo "Receive response: " . $response . " ";