论坛 › PHP › php使用swoole实现TCP服务

智多星星星星相映 发表于 2024-4-13 14:28:51

php使用swoole实现TCP服务

这里以在Yii框架下示例

一：swoole配置TCP

'swoole' => [
    // 日志文件路径
    'log_file' => '@console/log/swoole.log',
    // 设置swoole_server错误日志打印的等级，范围是0-5。低于log_level设置的日志信息不会抛出
    'log_level' => 1,
    // 进程的PID存储文件
    'pid_file' => '@console/log/swoole.server.pid',

    // HTTP协议配置
    'http' => [
      'host' => '0.0.0.0',
      'port' => '8889',

      // 异步任务的工作进程数量
      'task_worker_num' => 4,
    ],
    // TCP协议配置
    'tcp' => [
      'host' => '0.0.0.0',
      'port' => '14000',

      // 异步任务的工作进程数量
      'task_worker_num' => 4,

      // 启用TCP-Keepalive死连接检测
      'open_tcp_keepalive' => 1,
      // 单位秒，连接在n秒内没有数据请求，将开始对此连接进行探测
      'tcp_keepidle' => 5 * 60,
      // 探测的次数，超过次数后将close此连接
      'tcp_keepcount' => 3,
      // 探测的间隔时间，单位秒
      'tcp_keepinterval' => 60,

      // 心跳检测，此选项表示每隔多久轮循一次，单位为秒
      'heartbeat_check_interval' => 2 * 60,
      // 心跳检测，连接最大允许空闲的时间
      'heartbeat_idle_time' => 5 * 60,
    ]
],
二：swoole实现TCP服务基类

<?php
/**
* @link http://www.u-bo.com
* @copyright 南京友博网络科技有限公司
* @license http://www.u-bo.com/license/
*/

namespace console\swoole;

use Yii;
use yii\helpers\Console;
use yii\helpers\ArrayHelper;

/*
* Swoole Server基类
*
* @author wangjian
* @since 0.1
*/
abstract class BaseServer
{
    /**
   * @var Swoole\Server
   */
    public $swoole;
    /**
   * @var boolean DEBUG
   */
    public $debug = false;

    /**
   * __construct
   */
    public function __construct($httpConfig, $tcpConfig, $config = [])
    {
      $httpHost = ArrayHelper::remove($httpConfig, 'host');
      $httpPort = ArrayHelper::remove($httpConfig, 'port');
      $this->swoole = new \swoole_http_server($httpHost, $httpPort);
      $this->swoole->set(ArrayHelper::merge($config, $httpConfig));

      $this->swoole->on('start', [$this, 'onStart']);
      $this->swoole->on('request', [$this, 'onRequest']);
      $this->swoole->on('WorkerStart', [$this, 'onWorkerStart']);
      $this->swoole->on('WorkerStop', [$this, 'onWorkerStop']);
      $this->swoole->on('task', [$this, 'onTask']);
      $this->swoole->on('finish', [$this, 'onTaskFinish']);

      $this->swoole->on('shutdown', [$this, 'onShutdown']);

      $tcpHost = ArrayHelper::remove($tcpConfig, 'host');
      $tcpPort = ArrayHelper::remove($tcpConfig, 'port');
      $tcpServer = $this->swoole->listen($tcpHost, $tcpPort, SWOOLE_SOCK_TCP);
      $tcpServer->set($tcpConfig);
      $tcpServer->on('connect', [$this, 'onConnect']);
      $tcpServer->on('receive', [$this, 'onReceive']);
      $tcpServer->on('close', [$this, 'onClose']);
    }

    /*
   * 启动server
   */
    public function run()
    {
      $this->swoole->start();
    }

    /**
   * Server启动在主进程的主线程时的回调事件处理
   *
   * @param swoole_server $server
   */
    public function onStart(\swoole_server $server)
    {
      $startedAt = $this->beforeExec();

      $this->stdout("**Server Start**\n", Console::FG_GREEN);
      $this->stdout("master_pid: ");
      $this->stdout("{$server->master_pid}\n", Console::FG_BLUE);

      $this->onStartHandle($server);

      $this->afterExec($startedAt);
    }

    /**
   * 客户端与服务器建立连接后的回调事件处理
   *
   * @param swoole_server $server
   * @param integer $fd
   * @param integer $reactorId
   */
    abstract public function onConnect(\swoole_server $server, int $fd, int $reactorId);

    /**
   * 当服务器收到来自客户端的数据时的回调事件处理
   *
   * @param swoole_server $server
   * @param integer $fd
   * @param integer $reactorId
   * @param string $data
   */
    abstract public function onReceive(\swoole_server $server, int $fd, int $reactorId, string $data);

    /**
   * 当服务器收到来自客户端的HTTP请求时的回调事件处理
   *
   * @param swoole_http_request $request
   * @param swoole_http_response $response
   */
    abstract public function onRequest(\swoole_http_request $request, \swoole_http_response $response);

    /**
   * Worker进程/Task进程启动时发生
   *
   * @param swoole_server $server
   * @param integer $worker_id
   */
    abstract public function onWorkerStart(\swoole_server $server, int $worker_id);

    /**
   * Worker进程/Task进程终止时发生
   *
   * @param swoole_server $server
   * @param integer $worker_id
   */
    abstract public function onWorkerStop(\swoole_server $server, int $worker_id);

    /**
   * 异步任务处理
   *
   * @param swoole_server $server
   * @param integer $taskId
   * @param integer $srcWorkerId
   * @param mixed $data
   */
    abstract public function onTask(\swoole_server $server, int $taskId, int $srcWorkerId, mixed $data);

    /**
   * 异步任务处理完成
   *
   * @param swoole_server $server
   * @param integer $taskId
   * @param mixed $data
   */
    abstract public function onTaskFinish(\swoole_server $server, int $taskId, mixed $data);

    /**
   * 客户端与服务器断开连接后的回调事件处理
   *
   * @param swoole_server $server
   * @param integer $fd
   */
    abstract public function onClose(\swoole_server $server, $fd);

    /**
   * Server正常结束时的回调事件处理
   *
   * @param swoole_server $server
   */
    public function onShutdown(\swoole_server $server)
    {
      $startedAt = $this->beforeExec();

      $this->stdout("**Server Stop**\n", Console::FG_GREEN);
      $this->stdout("master_pid: ");
      $this->stdout("{$server->master_pid}\n", Console::FG_BLUE);

      $this->onShutdownHandle($server);

      $this->afterExec($startedAt);
    }

    /**
   * Server启动在主进程的主线程时的自定义事件处理
   *
   * @param swoole_server $server
   */
    protected function onStartHandle(\swoole_server $server)
    {

    }

    /**
   * Server正常结束时的自定义事件处理
   *
   * @param swoole_server $server
   */
    protected function onShutdownHandle(\swoole_server $server)
    {

    }

    /**
   * 获取请求路由
   *
   * @param swoole_http_request $request
   */
    protected function getRoute(\swoole_http_request $request)
    {
      return ltrim($request->server['request_uri'], '/');
    }

    /**
   * 获取请求的GET参数
   *
   * @param swoole_http_request $request
   */
    protected function getParams(\swoole_http_request $request)
    {
      return $request->get;
    }

    /**
   * 解析收到的数据
   *
   * @param string $data
   */
    protected function decodeData($data)
    {
      return json_decode($data, true);
    }

    /**
   * Before Exec
   */
    protected function beforeExec()
    {
      $startedAt = microtime(true);
      $this->stdout(date('Y-m-d H:i:s') . "\n", Console::FG_YELLOW);
      return $startedAt;
    }

    /**
   * After Exec
   */
    protected function afterExec($startedAt)
    {
      $duration = number_format(round(microtime(true) - $startedAt, 3), 3);
      $this->stdout("{$duration} s\n\n", Console::FG_YELLOW);
    }

    /**
   * Prints a string to STDOUT.
   */
    protected function stdout($string)
    {
      if (Console::streamSupportsAnsiColors(\STDOUT)) {
            $args = func_get_args();
            array_shift($args);
            $string = Console::ansiFormat($string, $args);
      }
      return Console::stdout($string);
    }
}
三：swoole操作类(继承swoole基类)

<?php
/**
* @link http://www.u-bo.com
* @copyright 南京友博网络科技有限公司
* @license http://www.u-bo.com/license/
*/

namespace console\swoole;

use Yii;
use yii\db\Query;
use yii\helpers\Console;
use yii\helpers\VarDumper;
use apps\sqjc\models\WaterLevel;
use apps\sqjc\models\WaterLevelLog;
use common\models\Bayonet;
use common\models\Device;
use common\models\DeviceCategory;

/**
* Swoole Server测试类
*
* @author wangjian
* @since 1.0
*/
class Server extends BaseServer
{
    /**
   * @inheritdoc
   */
    public function onConnect($server, $fd, $reactorId)
    {
      $startedAt = $this->beforeExec();

      $this->stdout("**Connection Open**\n", Console::FG_GREEN);
      $this->stdout("fd: ");
      $this->stdout("{$fd}\n", Console::FG_BLUE);

      $this->afterExec($startedAt);
    }

    /**
   * @inheritdoc
   */
    public function onReceive($server, $fd, $reactorId, $data)
    {
      $startedAt = $this->beforeExec();

      $this->stdout("**Received Message**\n", Console::FG_GREEN);

      $this->stdout("fd: ");
      $this->stdout("{$fd}\n", Console::FG_BLUE);

      $this->stdout("data: ");//接收的数据
      $this->stdout("{$data}\n", Console::FG_BLUE);



      $result = $server->send($fd, '回复消息');



      $this->afterExec($startedAt);
    }


    /**
   * @inheritdoc
   */
    public function onRequest($request, $response)
    {
      $startedAt = $this->beforeExec();

      $this->stdout("**HTTP Request**\n", Console::FG_GREEN);

      $this->stdout("fd: ");
      $this->stdout("{$request->fd}\n", Console::FG_BLUE);

      $response->status(200);
      $response->end('success');

      $this->afterExec($startedAt);
    }

    /**
   * @inheritdoc
   */
    public function onClose($server, $fd)
    {
      $startedAt = $this->beforeExec();

      $this->stdout("**Connection Close**\n", Console::FG_GREEN);

      $this->stdout("fd: ");
      $this->stdout("{$fd}\n", Console::FG_BLUE);

      $this->afterExec($startedAt);
    }



    /**
   * @inheritdoc
   */
    public function onTask($server, $taskId, $srcWorkerId, $data)
    {
      $startedAt = $this->beforeExec();

      $this->stdout("New AsyncTask: ");
      $this->stdout("{$taskId}\n", Console::FG_BLUE);
      $this->stdout("{$data}\n", Console::FG_BLUE);

      $server->finish($data);

      $this->afterExec($startedAt);
    }

    /**
   * @inheritdoc
   */
    public function onWorkerStop($server, $worker_id)
    {
      // Yii::$app->db->close();
    }
    /**
   * @inheritdoc
   */
    public function onWorkerStart($server, $worker_id)
    {
      // Yii::$app->db->open();
    }


    /**
   * @inheritdoc
   */
    public function onTaskFinish($server, $taskId, $data)
    {
      $startedAt = $this->beforeExec();

      $this->stdout("AsyncTask finished: ");
      $this->stdout("{$taskId}\n", Console::FG_BLUE);

      $this->afterExec($startedAt);
    }
}
四：操作TCP服务

<?php
/**
* @link http://www.u-bo.com
* @copyright 南京友博网络科技有限公司
* @license http://www.u-bo.com/license/
*/

namespace console\controllers;

use Yii;
use yii\helpers\Console;
use yii\helpers\FileHelper;
use yii\helpers\ArrayHelper;
use console\swoole\Server;

/**
* WebSocket Server controller.
*
* @see https://github.com/tystudy/yii2-swoole-websocket/blob/master/README.md
*
* @author wangjian
* @since 1.0
*/
class SwooleController extends Controller
{
    /**
   * @var string 监听IP
   */
    public $host;
    /**
   * @var string 监听端口
   */
    public $port;
    /**
   * @var boolean 是否以守护进程方式启动
   */
    public $daemon = false;
    /**
   * @var boolean 是否启动测试类
   */
    public $test = false;

    /**
   * @var array Swoole参数配置项
   */
    private $_params;

    /**
   * @var array Swoole参数配置项(HTTP协议)
   */
    private $_http_params;
    /**
   * @var array Swoole参数配置项(TCP协议)
   */
    private $_tcp_params;

    /**
   * @inheritdoc
   */
    public function beforeAction($action)
    {
      if (parent::beforeAction($action)) {
            //判断是否开启swoole拓展
            if (!extension_loaded('swoole')) {
                return false;
            }

            //获取swoole配置信息
            if (!isset(Yii::$app->params['swoole'])) {
                return false;
            }
            $this->_params = Yii::$app->params['swoole'];
            $this->_http_params = ArrayHelper::remove($this->_params, 'http');
            $this->_tcp_params = ArrayHelper::remove($this->_params, 'tcp');

            foreach ($this->_params as &$param) {
                if (strncmp($param, '@', 1) === 0) {
                  $param = Yii::getAlias($param);
                }
            }

            $this->_params = ArrayHelper::merge($this->_params, [
                'daemonize' => $this->daemon
            ]);

            return true;
      } else {
            return false;
      }
    }
    /**
   * 启动服务
   */
    public function actionStart()
    {
      if ($this->getPid() !== false) {
            $this->stdout("WebSocket Server is already started!\n", Console::FG_RED);
            return self::EXIT_CODE_NORMAL;
      }
      $server = new Server($this->_http_params, $this->_tcp_params, $this->_params);
      $server->run();
    }

    /**
   * 停止服务
   */
    public function actionStop()
    {
      $pid = $this->getPid();
      if ($pid === false) {
            $this->stdout("Tcp Server is already stoped!\n", Console::FG_RED);
            return self::EXIT_CODE_NORMAL;
      }

      \swoole_process::kill($pid);
    }

    /**
   * 清理日志文件
   */
    public function actionClearLog()
    {
      $logFile = Yii::getAlias($this->_params['log_file']);
      FileHelper::unlink($logFile);
    }

    /**
   * 获取进程PID
   *
   * @return false|integer PID
   */
    private function getPid()
    {
      $pidFile = $this->_params['pid_file'];
      if (!file_exists($pidFile)) {
            return false;
      }

      $pid = file_get_contents($pidFile);
      if (empty($pid)) {
            return false;
      }

      $pid = intval($pid);
      if (\swoole_process::kill($pid, 0)) {
            return $pid;
      } else {
            FileHelper::unlink($pidFile);
            return false;
      }
    }

    /**
   * @inheritdoc
   */
    public function options($actionID)
    {
      return ArrayHelper::merge(parent::options($actionID), [
            'daemon',
            'test'
      ]);
    }

    /**
   * @inheritdoc
   */
    public function optionAliases()
    {
      return ArrayHelper::merge(parent::optionAliases(), [
            'd' => 'daemon',
            't' => 'test',
      ]);
    }
}以上就是php使用swoole实现TCP服务的详细内容，更多关于php swoole实现TCP服务的资料请关注脚本之家其它相关文章！

来源:https://www.jb51.net/program/319161vhe.htm
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！

查看完整版本: php使用swoole实现TCP服务