如何在PHP中使用Netty4函数

sudo pecl install netty

<?php
use NettyBufferByteBuf;
use NettyHandlerChannelHandlerContext;
use NettyHandlerChannelInboundHandler;

class ServerHandler extends ChannelInboundHandler
{
    public function channelRead(ChannelHandlerContext $ctx, $msg)
    {
        // 解析消息体
        $byteBuf = ByteBuf::wrap($msg);
        $data = $byteBuf->readString();
        
        // 处理业务逻辑
        // ...
        
        // 响应消息
        $response = 'Hello, ' . $data . '!';
        $ctx->write($response);
    }
}

<?php
use NettyBootstrapServerBootstrap;
use NettyChannelSocketServerSocketChannel;
use NettyEventEventLoopGroup;
use NettyTransportSocketAddress;

class ServerLauncher 
{
    private $bossGroup;
    private $workerGroup;
    private $bootstrap;
    private $host;
    private $port;
    
    public function __construct($host, $port)
    {
        $this->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();
    }
}

<?php
$server = new ServerLauncher('127.0.0.1', 8080);
$server->run();

<?php
use NettyBufferByteBuf;
use NettyHandlerChannelHandlerContext;
use NettyHandlerChannelInboundHandler;

class ClientHandler extends ChannelInboundHandler
{
    private $response;
    
    public function channelRead(ChannelHandlerContext $ctx, $msg)
    {
        // 解析消息体
        $byteBuf = ByteBuf::wrap($msg);
        $this->response = $byteBuf->readString();
        
        // 关闭连接
        $ctx->close();
    }
    
    public function getResponse()
    {
        return $this->response;
    }
}

<?php
use NettyBootstrapBootstrap;
use NettyChannelChannelOption;
use NettyChannelSocketClientSocketChannel;
use NettyEventEventLoopGroup;
use NettyTransportInetSocketAddress;

class ClientLauncher
{
    private $group;
    private $bootstrap;
    private $host;
    private $port;
    
    public function __construct($host, $port)
    {
        $this->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();
    }
}

<?php
$client = new ClientLauncher('127.0.0.1', 8080);
$response = $client->connect('Jack');
echo "Receive response: " . $response . "
";