您的位置：首页 > 编程学习 > > 正文

drools机制（Swoole实现异步投递task任务案例详解）

更多时间：2022-03-31 20:07:47 类别：编程学习浏览量：1067

drools机制

Swoole实现异步投递task任务案例详解

本文实例讲述了swoole实现异步投递task任务案例。分享给大家供大家参考，具体如下：

【使用场景】

swolle的task模块可以用来做一些异步的慢速任务、耗时场景。如webim中发广播，发送邮件等，把这些任务丢给task进程之后，worker进程可以继续处理新的数据请求，任务完成后会异步通知worker进程告诉它此任务已经完成。此外利用task还可以实现php的数据库连接池，异步队列等。

【使用须知】

必须设置task进程数：

投递一个异步任务到task_worker池中：server->task

必须注册ontask、onfinish2个事件回调函数。

【示例】

以创建一个websocket服务异步投递任务为例：

ws_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 <?php

class ws {

public $ws = null;

public function __construct() {

$this->ws = new swoole_websocket_server("0.0.0.0", 9501);

$this->ws->set([

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

'task_worker_num' => 2, //task进程数

]);

$this->ws->on("open", [$this, 'onopen']);

$this->ws->on("message", [$this, 'onmessage']);

$this->ws->on("task", [$this, 'ontask']);

$this->ws->on("finish", [$this, 'onfinish']);

$this->ws->on("close", [$this, 'onclose']);

$this->ws->start();

}

//建立连接回调

public function onopen($ws, $request) {

echo "{$request->fd}建立了连接";

}

//接受消息回调

public function onmessage($ws, $frame) {

//worker进程异步投递任务到task_worker进程中

$data = [

'fd' => $frame->fd,

];

$ws->task($data);

//服务器返回

echo "服务器发送消息:666";

}

//完成异步任务回调

public function ontask($serv, $task_id, $worker_id, $data) {

var_dump($data);

//模拟慢速任务

sleep(5);

//返回字符串给worker进程——>触发onfinish

return "success";

}

//完成任务投递回调

public function onfinish($serv, $task_id, $data) {

//task_worker进程将任务处理结果发送给worker进程

echo "完成任务{$task_id}投递处理结果：{$data}";

}

//关闭连接回调

public function onclose($ws, $fd) {

echo "{$fd}关闭了连接";

}

}

$obj = new ws();

前端页面js监听：

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 <!doctype html public "-//w3c//dtd xhtml 1.0 transitional//en" "http://www.w3.org/tr/xhtml1/dtd/xhtml1-transitional.dtd">

<html xmlns="http://www.w3.org/1999/xhtml">

<head>

<title>websocket</title>

</head>

<body>

</body>

<script type="text/javascript">

var websocket = new websocket('ws://127.0.0.1:9501');

websocket.onopen = function (evt) { onopen(evt) };

websocket.onclose = function (evt) { onclose(evt) };

websocket.onmessage = function (evt) { onmessage(evt) };

websocket.onerror = function (evt) { onerror(evt) };

function onopen(evt) {

console.log("connected to websocket server.");

//*发送消息到websocket服务器

websocket.send('666');

}

function onclose(evt) {

console.log("disconnected");

}

function onmessage(evt) {

console.log('retrieved data from server: ' + evt.data);

}

function onerror(evt) {

console.log('error occured: ' + evt.data);

}

</script>

</html>

开启websocket服务：

1	`php ws_server.php`

前后刷新了两次页面，websocket服务器监听结果：

drools机制（Swoole实现异步投递task任务案例详解）

（服务器会先返回消息给客户端，然后再执行投递任务）

希望本文所述对大家php程序设计有所帮助。

原文链接：https://blog.csdn.net/msllws/article/details/84782809

标签：Swoole 异步 task

上一篇：详解JS中你不知道的各种循环测速（详解JS中你不知道的各种循环测速）

下一篇：CSS filter:hue-rotate色调旋转滤镜实现按钮批量生产（CSS filter:hue-rotate色调旋转滤镜实现按钮批量生产）

您可能感兴趣

drools机制（Swoole实现异步投递task任务案例详解）

drools机制

热门推荐

排行榜