测试环境：win 10

think-worker 默认有命令

1
php think worker:gateway

但是如果在 win 下运行，会报错

GatewayWorker Not Support On Windows

但是这并不是说 gatewa 不能再 windows 上运行，而是 gateway 需要启动好几个命令行，windows 下无法直接处理，所以如果想要使用 think-worker 下的 gateway，还需要改造下。
新建 command 命令，例如新建 workman

附：自定义 TP 命令行

命令行文件 application\common\command\Workerman.php

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
<?php
/**
 * Created by PhpStorm.
 * User: 投实科技
 * Date: 2021-07-26
 * Time: 11:20:11
 * Info:
 */

namespace app\common\command;

use GatewayWorker\BusinessWorker;
use GatewayWorker\Gateway;
use GatewayWorker\Register;
use think\console\Command;
use think\console\Input;
use think\console\input\Argument;
use think\console\input\Option;
use think\console\Output;
use think\facade\Config;
use Workerman\Worker;

/**
 * Worker 命令行
 */
class Workerman extends Command
{

    protected function configure()
    {
        $this->setName('workerman')->addArgument('service', Argument::OPTIONAL,
                'workerman service: gateway|register|businessworker', null)->addOption('host', 'H',
                Option::VALUE_OPTIONAL, 'the host of workerman server', null)->addOption('port', 'P',
                Option::VALUE_OPTIONAL, 'the port of workerman server', null)->addOption('daemon', 'd',
                Option::VALUE_OPTIONAL,
                'Run the workerman server in daemon mode.')->setDescription('workerman Server for ThinkPHP');
    }

    public function execute(Input $input, Output $output)
    {
        $service = $input->getArgument('service');

        $option = Config::pull('gateway_worker');

        if ($input->hasOption('host')) {
            $host = $input->getOption('host');
        } else {
            $host = ! empty($option['host']) ? $option['host'] : '0.0.0.0';
        }

        if ($input->hasOption('port')) {
            $port = $input->getOption('port');
        } else {
            $port = ! empty($option['port']) ? $option['port'] : '2347';
        }

        $registerAddress = ! empty($option['registerAddress']) ? $option['registerAddress'] : '127.0.0.1:1236';
        switch ($service) {
            case 'register':
                $this->register($registerAddress);
                break;
            case 'businessworker':
                $this->businessWorker($registerAddress,
                    isset($option['businessWorker']) ? $option['businessWorker'] : []);
                break;
            case 'gateway':
                $this->gateway($registerAddress, $host, $port, $option);
                break;
            default:
                $output->writeln("<error>Invalid argument action:{$service}, Expected gateway|register|businessworker .</error>");
                exit(1);
                break;
        }

        Worker::runAll();
    }

    /**
     * 启动register
     * @access public
     *
     * @param string $registerAddress
     *
     * @return void
     */
    public function register($registerAddress)
    {
        // 初始化register
        new Register('text://'.$registerAddress);
    }

    /**
     * 启动businessWorker
     * @access public
     *
     * @param string $registerAddress registerAddress
     * @param array  $option          参数
     *
     * @return void
     */
    public function businessWorker($registerAddress, $option = [])
    {
        // 初始化 bussinessWorker 进程
        $worker = new BusinessWorker();

        $this->option($worker, $option);

        $worker->registerAddress = $registerAddress;
    }

    /**
     * 启动gateway
     * @access public
     *
     * @param string  $registerAddress registerAddress
     * @param string  $host            服务地址
     * @param integer $port            监听端口
     * @param array   $option          参数
     *
     * @return void
     */
    public function gateway($registerAddress, $host, $port, $option = [])
    {
        // 初始化 gateway 进程
        if ( ! empty($option['socket'])) {
            $socket = $option['socket'];
            unset($option['socket']);
        } else {
            $protocol = ! empty($option['protocol']) ? $option['protocol'] : 'websocket';
            $socket   = $protocol.'://'.$host.':'.$port;
            unset($option['host'], $option['port'], $option['protocol']);
        }

        $gateway = new Gateway($socket, isset($option['context']) ? $option['context'] : []);

        // 以下设置参数都可以在配置文件中重新定义覆盖
        $gateway->name                 = 'Gateway';
        $gateway->count                = 4;
        $gateway->lanIp                = '127.0.0.1';
        $gateway->startPort            = 2000;
        $gateway->pingInterval         = 30;
        $gateway->pingNotResponseLimit = 0;
        $gateway->pingData             = '{"type":"ping"}';
        $gateway->registerAddress      = $registerAddress;

        // 全局静态属性设置
        foreach ($option as $name => $val) {
            if (in_array($name, ['stdoutFile', 'daemonize', 'pidFile', 'logFile'])) {
                Worker::${$name} = $val;
                unset($option[$name]);
            }
        }

        $this->option($gateway, $option);
    }

    /**
     * 设置参数
     * @access protected
     *
     * @param Worker $worker Worker对象
     * @param array  $option 参数
     *
     * @return void
     */
    protected function option($worker, array $option = [])
    {
        // 设置参数
        if ( ! empty($option)) {
            foreach ($option as $key => $val) {
                $worker->$key = $val;
            }
        }
    }
}

这个文件放哪里都无所谓，只要和对应的 command 参数配置对应就好了
在application\command.php命令行参数配置文件中添加

1
2
3
4
return [
    'workerman' => '\app\common\command\Workerman',
];

然后 windows 通过命令行启动 gateway。

1
2
3
php think workerman register
php think workerman businessworker
php think workerman gateway

对应 Workman.php 设置的命令参数，如果需要重新命名，注意对应关系。

进阶 1

每次都启动三个命令框，有点麻烦，所以调整了下，写了三个 bat 文件
register.bat

1
2
@echo off
php E:\WWW\tp6\think workerman register

business.bat

1
2
@echo off
php E:\WWW\tp6\think workerman businessworker

gateway.bat

1
2
@echo off
php E:\WWW\tp6\think workerman gateway

又写了一个 all.bat

1
2
3
4
@echo off
start call E:\WWW\tp6\register.bat
start call E:\WWW\tp6\business.bat
start call E:\WWW\tp6\gateway.bat

这样一个 bat 就搞定了，但是每次都有 3 个弹窗也不好。

进阶 2

于是又写了一个 all.vbs

1
2
3
4
set ws=WScript.CreateObject("WScript.Shell")
ws.Run "E:\WWW\tp6\register.bat",0
ws.Run "E:\WWW\tp6\business.bat",0
ws.Run "E:\WWW\tp6\gateway.bat",0

这样就可以启动一个文件，而且没有弹窗。
当然还可以放在开机启动文件夹里面，这样就能随着开机自启动，目录如下（该路径为 win7 下路径，其他系统未知）

C:\Users\用户名\AppData\Roaming\Microsoft\Windows\Start Menu\Programs\Startup