PHP code example of wp-breeder / swoft-socket

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

    

wp-breeder / swoft-socket example snippets

    // 配置启动扫描
    'bootScan' => [
        // code...
        // 把 sockerListener 注解的目录添加到启动扫描
        'App\Listener'
    ],
    // 指定扫描组件
    'components' => [
            'custom' => [
                'Swoft\\Socket\\'
            ],
        ],

    //for socket component
    'server' => [
            //code ...
            // socketable 配置是否开启socket监听
            'socketable' => env('SOCKETABLE', false),
           
        ],
    
    // for socket component test
        'socket' => [
            [
                'host' => env('SOCKET_TCP_HOST', '0.0.0.0'),
                'port' => env('SOCKET_TCP_PORT', 8010),
                'mode' => env('SOCKET_TCP_MODE', SWOOLE_PROCESS),
                'type' => env('SOCKET_TCP_TYPE', SWOOLE_SOCK_TCP),
                //server 名称,必须设置，如果未设置则不监听(用于区分不同server 设置不同的回调，如果重复，则会覆盖)
                //如果是单独开启，第一个不设置name则会报错
                'name' => 'tcp'
            ],
            [
                'host' => env('SOCKET_UDP_HOST', '0.0.0.0'),
                'port' => env('SOCKET_UDP_PORT', 8011),
                'mode' => env('SOCKET_UDP_MODE', SWOOLE_PROCESS),
                'type' => env('SOCKET_UDP_TYPE', SWOOLE_SOCK_UDP),
                'name' => 'udp'
            ],
        ],

    /**
     *   监听多个事件
     * @SocketListener({
     *     SwooleEvent::ON_CONNECT,
     *     SwooleEvent::ON_RECEIVE,
     *     SwooleEvent::ON_CLOSE,
     * },
     *   监听端口的名称，与socket配置文件中的name对应(如重复则最后一个生效，不存在则监听不生效)
     *     name="tcp"
     * )

namespace SwoftTest\Socket\Testing\Listeners;

use Swoft\Bootstrap\Listeners\Interfaces\CloseInterface;
use Swoft\Bootstrap\Listeners\Interfaces\ConnectInterface;
use Swoft\Bootstrap\Listeners\Interfaces\ReceiveInterface;
use Swoft\Socket\Bean\Annotation\SocketListener;
use Swoft\Socket\Event\SwooleEvent;
use Swoole\Server;

/**
 * tcp 监听 demo
 * Class SocketListenerTest
 * @package SwoftTest\Socket\Testing\Listeners
 * @SocketListener({
 *     SwooleEvent::ON_CONNECT,
 *     SwooleEvent::ON_RECEIVE,
 *     SwooleEvent::ON_CLOSE,
 * },
 *     name="tcp"
 * )
 */
class TcpListener implements ReceiveInterface, CloseInterface, ConnectInterface
{
    public function onConnect(Server $server, int $fd, int $reactorId)
    {
        echo "tcp connect" . PHP_EOL;
    }

    public function onReceive(Server $server, int $fd, int $reactorId, string $data)
    {
        echo "tcp receive data: " . $data . PHP_EOL;
    }

    public function onClose(Server $server, int $fd, int $reactorId)
    {
        echo "tcp close" . PHP_EOL;
    }

}

namespace SwoftTest\Socket\Testing\Listeners;

use Swoft\Socket\Event\SwooleEvent;
use Swoft\Bootstrap\Listeners\Interfaces\PacketInterface;
use Swoft\Socket\Bean\Annotation\SocketListener;
use Swoole\Server;

/**
 * udp 监听 demo
 * Class PacketListener
 * @package SwoftTest\Socket\Testing\Listeners
 * @SocketListener(event={SwooleEvent::ON_PACKET}, name="udp")
 */
class PacketListener implements PacketInterface
{
    public function onPacket(Server $server, string $data, array $clientInfo)
    {
        echo "udp receive data: " . $data;
    }
}

shell
    php bin/swoft socket:start