我使用TP框架的command 結(jié)合 workerman 來(lái)使用。
具體是在command里新建2個(gè)文件，然后通過php think PriceOkex start 、php think PriceBinance start 來(lái)啟動(dòng)，發(fā)現(xiàn)只能啟動(dòng)一個(gè)，另一個(gè)直接報(bào)錯(cuò)說worker已經(jīng)在執(zhí)行了。報(bào)錯(cuò)內(nèi)容
Workerman[think] start in DEBUG mode
Workerman[think] already running
應(yīng)該是 入口文件 think 重名了，有沒有什么方式讓workerman 以 think文件后面一個(gè)參數(shù)（比如上面的PriceOkex、PriceBinance）作為這個(gè)key ？

文件內(nèi)容如下

<?php
declare (strict_types=1);
namespace app\command;
use Workerman\Connection\AsyncTcpConnection;
use Workerman\Worker;

class PriceOkex extends Command
{
    protected function configure()
    {
        // 指令配置
        $this->setName('PriceOkex')
            ->addArgument('action', Argument::OPTIONAL,
                "start|stop|restart|reload|status|connections", 'start')
            ->addOption('mode', 'm', Option::VALUE_OPTIONAL,
                'Run the workerman server in daemon mode.')
            ->setDescription('the workerman command');
    }
    protected function execute(Input $input, Output $output)
    {
        // 指令輸出
        $output->writeln('convert start');
        $action = $input->getArgument('action');
        $mode = $input->getOption('mode');
        // 重新構(gòu)造命令行參數(shù),以便兼容workerman的命令
        global $argv;
        $argv = [];
        array_unshift($argv, 'think', $action);
        if ($mode == 'd') {
            $argv[] = '-d';
        } else {
            if ($mode == 'g') {
                $argv[] = '-g';
            }
        }
        $worker_1 = new Worker();
        $worker_1->name = 'PriceOkex';
        $worker_1->id = 2;
        $worker_1->onWorkerStart = function ($worker) {
            $pRedis = Predis::getInstance();
            $con = new AsyncTcpConnection('ws://ws.okx.com:8443/ws/v5/public');
            $con->transport = 'ssl';
            $con->onConnect = function (AsyncTcpConnection $con) {
            };
            $con->onMessage = function (AsyncTcpConnection $con, $data) use (
                $pRedis
            ) {
            };
            $con->connect();
        };
        Worker::runAll();
    }
}

另一個(gè)文件如下

<?php
declare (strict_types=1);
namespace app\command;
use Workerman\Connection\AsyncTcpConnection;
use Workerman\Worker;

class PriceBinance extends Command
{
    protected function configure()
    {
        // 指令配置
        $this->setName('PriceBinance')
            ->addArgument('action', Argument::OPTIONAL,
                "start|stop|restart|reload|status|connections", 'start')
            ->addOption('mode', 'm', Option::VALUE_OPTIONAL,
                'Run the workerman server in daemon mode.')
            ->setDescription('the workerman command');
    }

    protected function execute(Input $input, Output $output)
    {
        // 指令輸出
        $output->writeln('convert start');
        $action = $input->getArgument('action');
        $mode = $input->getOption('mode');
        // 重新構(gòu)造命令行參數(shù),以便兼容workerman的命令
        global $argv;
        $argv = [];
        array_unshift($argv, 'think', $action);
        if ($mode == 'd') {
            $argv[] = '-d';
        } else {
            if ($mode == 'g') {
                $argv[] = '-g';
            }
        }
        $worker_1 = new Worker();
        $worker_1->name = 'PriceBinance';
        $worker_1->id = 1;
        $worker_1->onWorkerStart = function ($worker) {
            $pRedis = Predis::getInstance();
            $con
                = new AsyncTcpConnection('ws://stream.binance.com:9443/ws/btcusdt@aggTrade');
            $con->transport = 'ssl';
            $con->onConnect = function (AsyncTcpConnection $con) {
            };
            $con->onMessage = function (AsyncTcpConnection $con, $data) use (
                $pRedis
            ) {
            };
            $con->connect();
        };
        Worker::runAll();
    }
}