swoft socket
1.0.3
基于 swoft 的 socket
组件,支持 tcp/udp
多端口监听,详细内容参考swoole wiki。
composer require wp-breeder/swoft-socket
/project-to-path/config/properties/app
中添加配置: // 配置启动扫描
'bootScan' => [
// code...
// 把 sockerListener 注解的目录添加到启动扫描
'AppListener'
],
// 指定扫描组件
'components' => [
'custom' => [
'Swoft\Socket\'
],
],
/project-to-path/config/server
中添加配置: //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'
],
],
rpc
、http
混合使用新增注解
@SocketListener
, 使用方法大致与@ServerListener
一致,不同是需要指定该监听器监听的端口。
/**
* 监听多个事件
* @SocketListener({
* SwooleEvent::ON_CONNECT,
* SwooleEvent::ON_RECEIVE,
* SwooleEvent::ON_CLOSE,
* },
* 监听端口的名称,与socket配置文件中的name对应(如重复则最后一个生效,不存在则监听不生效)
* name="tcp"
* )
rpc
、 http
、 ws
一致。(若监听多个,默认第一个配置为master server, 其他配置单独监听指定端口) php bin/swoft socket:start
namespace SwoftTestSocketTestingListeners;
use SwoftBootstrapListenersInterfacesCloseInterface;
use SwoftBootstrapListenersInterfacesConnectInterface;
use SwoftBootstrapListenersInterfacesReceiveInterface;
use SwoftSocketBeanAnnotationSocketListener;
use SwoftSocketEventSwooleEvent;
use SwooleServer;
/**
* tcp 监听 demo
* Class SocketListenerTest
* @package SwoftTestSocketTestingListeners
* @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 SwoftTestSocketTestingListeners;
use SwoftSocketEventSwooleEvent;
use SwoftBootstrapListenersInterfacesPacketInterface;
use SwoftSocketBeanAnnotationSocketListener;
use SwooleServer;
/**
* udp 监听 demo
* Class PacketListener
* @package SwoftTestSocketTestingListeners
* @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;
}
}
The Component is open-sourced software licensed under the Apache license.