Swoole使用纯C语言编写，提供了PHP语言的异步多线程服务器，异步 TCP/UDP 网络客户端，异步 MySQL，异步 Redis，数据库连接池，AsyncTask，消息队列，毫秒定时器，异步文件读写，异步DNS查询。 Swoole内置了Http/WebSocket服务器端/客户端、Http2.0服务器端，完美支持PHP语言。本文讲解Linux下搭建swoole实现php消息推送的方法。

swoole简介

Swoole是一个面向生产环境的 PHP 异步网络通信引擎，使 PHP 开发人员可以编写高性能的异步并发 TCP、UDP、Unix Socket、HTTP，WebSocket 服务。Swoole 可以广泛应用于互联网、移动通信、企业软件、云计算、网络游戏、物联网（IOT）、车联网、智能家居等领域。 使用 PHP + Swoole 作为网络通信框架，可以使企业 IT 研发团队的效率大大提升。

Swoole不是一个像Zend Framework、CakePHP、Yii、symfony、ThinkPHP等一样的框架，也不是一个像WordPress、Drupal、Discuz、UChome等开源产品看齐的项目。 Swoole的目标是向Java框架、Ruby On Rails、Python DjangoPylons等一流框架发起挑战。

Swoole虽然是标准的PHP扩展，实际上与普通的扩展不同。普通的扩展只是提供一个库函数。而Swoole扩展在运行后会接管PHP的控制权，进入事件循环。当IO事件发生后底层会自动回调指定的PHP函数。

包含以下几个特色功能：

1、 类似ORM的数据查询，提供SQL封装器，让MySQL的SQL与PHP的Array，会话，Cache无缝结合。

2、App MVC分层结构，有效的程序结构分层，提高程序的可维护性和扩展性，实现低耦合，基于接口开发。

3、集成大量，实用的功能，比如方便的数据库操作，模板操作，缓存操作，系统配置，表单处理，分页，数据调用，字典操作，上传处理，内容编辑，调试等。

4、模板-数据反射系统，可以直接在模板中调用数据，提供很多标签，可以无需修改程序，只修改模板，即可实现网站各类更新维护工作。

另外的几个功能

1、Swoole包含了大量类，提供众多的功能扩展，基本上Web开发能够用到的功能类，大部分都可以在Swoole框架中找到。

2、Swoole拥有插件系统，Fckeditor、Adodb、pscws中文分词、中文全文索引系统、最新的Key-Value数据库思想，TokyoTyrant，可以无限扩展框架的功能。

安装swoole服务

1.下载swoole源码，下载地址： https://github.com/swoole/swoole-src/releases

2.将tar包上传到/usr/local/src/swoole下面，这里面存储安装源文件。

3.解压源文件，tar –xvfswoole.tar

4.进入到刚解压的目录下输入命令phpize

5.注意：phpize是php-devel中的东西，它可以给PHP动态添加扩展，所以，请确保你的机器上安装了php-devel软件包。

6.接着，依次输入如下命令：./configure，执行编译检测make，编译swoole

7.缺少pcre和pcre-devel相关软件包，安装上即可。

8.sudo make install

9.php.ini一般在etc下面 编译安装成功后，我们还需要修改php.ini，在其中加入swoole.so扩展：

10.extension=swoole.so

11.输入php -m中能查看到swoole说明扩展安装成功。

安装apache启动swoole服务

（1）测试是否安装正确启动swoole Php服务

（2）在apache中添加server.php文件，和client.php文件。一般目录在var/www/html下面

（3）打开两个终端 在这两个文件所在的目录下面打开这两个文件，可以实现socket长连接服务。

安装lsof：yum -y install lsof

Server端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

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

class WebSocketService {

   private static $instance = NULL;

   public $tagindex = 0;

   public    $server    = null;

   public   $office_cache = null;

   public    $timer_arr = [];    //该变量保存所有的定时器任务ID，每一个客户端可以通过$timer_arr[客户端ID]

   得到该客户端建立的所有定时器

   public $conf      = [

       'host'            => '0.0.0.0',

       'port'            => 9999,     //服务使用端口

       'worker_num'      => 2,         //启动worker进程数

       'task_worker_num' => 8,           //启动task进程数

       'is_daemonize'    => 0,          //是否后台运行：0-否，1-是

       'log_file'        =>'/tmp/swoole_webSocket_server.log',    //日志文件路径

       'abc'              =>0,

   ];

   public function getTagIndex() {

       return $this->conf['abc'];

    }

   public function setSetTagIndex($index) {

       $this->conf['abc'] = 100;

       echo $this->getTagIndex();

    }

   public function __construct($config = []) {

       $this->office_cache = array('1' => '1', '3'=>'2');

       $this->conf = array_merge($this->conf, (array)$config);

    }

   //静态方法，返回此类唯一实例

   public static function getInstance(){

       if(empty(self::$instance)){

           echo "instance \n";

           self::$instance=new WebSocketService();

       }

       return self::$instance;

    }

   /**

    * 服务器端运行webSocket的入口

    */

   public function run() {

       try {

           $this->server = new \swoole_websocket_server($this->conf['host'],$this->conf['port']);

           $this->server->set(

                [

                    'worker_num'      => $this->conf['worker_num'],

                    'task_worker_num' =>$this->conf['task_worker_num'],

                    'daemonize'       => $this->conf['is_daemonize'],

                    'log_file'        => $this->conf['log_file'],

                ]

           );

           //注册方法列表

           $this->server->on('open', [$this, 'open']);

           $this->server->on('message', [$this, 'message']);

           $this->server->on('task', [$this, 'task']);

           $this->server->on('finish', [$this, 'finish']);

           $this->server->on('close', [$this, 'close']);

           $this->server->start();

       } catch (\Exception $e) {

           var_dump($e->getCode() . ':' . $e->getMessage());

       }

    }

   /**

    * 建立socket链接时，执行方法

    * @param $server

    * @param $request

    */

   public function open($server, $request) {

       $data = [

           'client_id' => $request->fd,

           'request'   => $request

       ];

       echo 'open<<'.$data['client_id'];

       $this->doOpen($data);

    }

   /**

    * 发送消息时，执行方法

    * @param $server

    * @param $frame

    */

   public function message($server, $frame) {

       echo "GET_mesage\n";

       $data = [

           'client_id' => $frame->fd,

           'data'      => $frame->data,

           'frame'     => $frame,

       ];

       $this->doMessage($data);

    }

   /**

    * 执行具体任务

    * @param $server

    * @param $task_id

    * @param $from_id

    * @param $data

    */

   public function task($server, $task_id, $from_id, $data) {

       $data['task_id'] = $task_id;

       $data['from_id'] = $from_id;

       $this->doTask($data);

    }

   /**

    * 任务结果处理

    * @param $server    服务器对象

    * @param $taskId    任务进程ID

    * @param $data

    */

   public function finish($server, $taskId, $data) {

       $data['task_id'] = $taskId;

       $this->doFinish($data);

    }

   /**

    * 关闭链接

    * @param $server        服务器对象

    * @param $client_id     客户端唯一标识

    */

   public function close($server, $client_id) {

       $data = [

           'client_id' => $client_id

       ];

       $this->doClose($data);

    }

   /**

    * 客户端成功连接到服务器时，会触发该方法

     * 子类根据需求重写该方法

    * @param $data

    * [

    *    'client_id',    //客户端唯一标识

    *    'data',        //一些请求数据

    *    'frame',        //swoole的数据

    * ];

    */

   public function doOpen($data) {

       echo "建立连接成功";

    }

   /**

    * 得到Swoole Websocket Server

    *

    * @return null|\swoole_websocket_server

    */

   public function getServer()

    {

       return $this->server;

    }

   /**

    * 收到客户端发来的消息，会触发该方法

    * 子类根据需求重写该方法

    * @param $data

    * [

    *    'client_id',    //客户端唯一标识

    *    'data',        //客户端发送过来的消息(数据)

    *    'frame',        //swoole的数据

    * ];

    */

   public function doMessage($data) {

       $info = json_decode($data['data'],true);

       $officeid = $info['officeid'];

       $client_id = $data['client_id'];

       echo"<<<<".$officeid.">>>>".$client_id."\r\n";

       if ($officeid == 1) {

           $this->sendMsgToClient('2',array('msg' =>'我是1号场地发送给你数据'));

       } else {

           $this->sendMsgToClient('1',array('msg' =>'我是3号场地发送给你数据'));

       }

    }

   /**

    * 具体的工作任务。需要通过 $this->doJob()来触发

    * 子类根据需求重写该方法

    * @param $data

    * [

    *    'client_id',    //客户端唯一标识

    * ];

    */

   public function doTask($data) {

    }

   /**

    * 工作的结果处理。

     * 子类根据需求重写该方法

    * @param $data

    * [

    *    'client_id',    //客户端唯一标识

    * ];

    */

   public function doFinish($data) {

    }

   /**

    * 客户端断开时会自动触发该方法

    * 子类根据需求重写该方法

    * @param $data

    * [

    *    'client_id',    //客户端唯一标识

    * ];

    */

   public function doClose($data) {

    }

   /**

    * 发送任务

    * @param $data    必须是数组，且要有$data['client_id']

    */

   public function doJob($data) {

       $this->server->task($data);

    }

   public function finishJob($data) {

       $this->server->finish($data);

    }

   /**

    * 发送消息到客户端

    * @param $client_id

    * @param $msg

    */

   public function sendMsgToClient($client_id, $msg) {

       echo "发送信息给客户端：{$client_id} | {$msg['action']['name']} | " . date('Y-m-dH:i:s') . "\r\n";

       $this->server->push($client_id, json_encode($msg));

    }

   /**

    * 关闭客户端链接

    * @param $client_id

    */

   public function closeClient($client_id) {

       $this->server->close($client_id);

    }

   /**

    * 添加定时器

    * @param $client_id

    * @param $tick_time

    */

   public function addTimer($client_id, $tick_time) {

       //暂未实现,先使用swoole原生写法

    }

   /**

    * 清除定时器

    * @param $client_id

    * @param $arr

    */

   public function clearTimer($client_id, &$arr) {

       if (is_array($arr)) {

           foreach ($arr[$client_id] as $val) {

                if (is_array($val)) {

                    foreach ($val as $v) {

                        swoole_timer_clear($v);

                    }

                } else {

                    swoole_timer_clear($val);

                }

           }

       }

       unset($arr[$client_id]);

    }

}

html前端javascript程序

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

$(document).ready(function(){

    varwsurl = "ws://182.92.101.206:9999/";

    console.log(wsurl);

    varwebsocket = new WebSocket(wsurl);

    websocket.onopen= function(evt){

    console.log('Server:  打开WebSocket连接');

    };

    websocket.onclose= function(evt){

           console.log('Server:  关闭WebSocket连接');

    };

    websocket.onmessage= function(evt){

           varres = JSON.parse(evt.data);

           console.log('Server:  收到消息(来自：'+res+'请求)');

           console.log(res);

    };

    websocket.οnerrοr= function(evt){

           console.log('Server:  出现错误');

           console.log(evt.data);

    }

    functiondoSend(msg){

           console.log('Client:发送消息  ' + msg);

           websocket.send(msg);

    }

});

启动start.php文件

启动start.php文件，cd到指定目录下，然后PHP-CLI运行php start.php。这种方式是没有启用线程保护的关掉后程序结束线程还在占用。

1

2

3

4

5

6

require'src/WebSocketSwoole/WebSocketService.php';

// require './WebSocketService.php';

session_start();

// $demoService = new\WebSocketSwoole\WebSocketService();

$demoService =\WebSocketSwoole\WebSocketService::getInstance();

$demoService->run();

总结

到此这篇关于Linux下搭建swoole实现php消息推送的方法的文章就介绍到这了

# linux # swoole # php
Logo
亚马逊云科技技术品牌专区

更多推荐

cover

基于STM32的全屋环境智能监测与预警终端设计

avatar 亚马逊云科技技术品牌专区

Keras：面向人类的深度学习库

Keras3支持多后端（TensorFlow、PyTorch、JAX），通过设置环境变量切换，兼容指定版本。pip安装后可用Sequential API快速构建CNN模型，如MNIST分类示例，实

avatar 亚马逊云科技技术品牌专区

AI行业日报｜2026-09-25：5个热点事件

本期行业动态聚焦于端侧算力重构、自主智能体工作流、开发工具经济模型、网络隔离架构设计与公共部门合规审查。以下结合一线技术场景进行结构化梳理，供 AI 研究员与软件工程团队参考。 PrismML 正将其轻量级语言模型适配至搭载高通处理器的智能眼镜终端 1 。该平台的核心战略指向开源权重模型的本地化运行，旨在最大化挖掘穿戴设备现有算力的利用效率 1 。对于嵌入式与边缘计算开发者而言，此类微型模型向低功

avatar 亚马逊云科技技术品牌专区