个人中心
文章发布
退出
作者热门文章
- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
25
4
CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章php基于 swoole 实现的异步处理任务功能示例由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.
本文实例讲述了php基于 swoole 实现的异步处理任务功能。分享给大家供大家参考，具体如下:
安装swoole:
下载官方swoole压缩包，解压进入目录 。
|
1
2
3
4
|
$
cd
swoole
# 进入 swoole 目录
$ phpize
$ .
/configure
--with-php-config=
/usr/local/php/bin/php-config
#注意查看服务器上是否有这个路径
$
make
&&
make
install
|
修改php.in文件 。
|
1
|
vi
/usr/local/php/lib/php
.ini
|
增加如下内容 。
|
1
|
extension =
"/usr/local/php/lib/php/extensions/no-debug-non-zts-20160303/swoole.so"
//
版本不同路径可能不同
|
保存后重启php-fpm 。
|
1
|
$
/etc/init
.d
/php-fpm
restart
|
php -m 命令查看是否添加成功 成功则会看到有swoole模块 。
|
1
|
$ php -m
|
服务端作为守护进程监控任务，新建server.php:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
<?php
$serv
=
new
Swoole\Server(
"127.0.0.1"
, 9502);
$serv
->set(
array
(
'task_worker_num'
=> 4));
$serv
->on(
'Receive'
,
function
(
$serv
,
$fd
,
$from_id
,
$data
) {
$task_id
=
$serv
->task(
"Async"
);
echo
"Dispath AsyncTask: id=$task_id\n"
;
});
$serv
->on(
'Task'
,
function
(
$serv
,
$task_id
,
$from_id
,
$data
) {
echo
"New AsyncTask[id=$task_id]"
.PHP_EOL;
$serv
->finish(
"$data -> OK"
);
});
$serv
->on(
'Finish'
,
function
(
$serv
,
$task_id
,
$data
) {
echo
"AsyncTask[$task_id] Finish: $data"
.PHP_EOL;
});
$serv
->start();
|
用命令行模式打开 。
|
1
|
php server.php
|
新建一个client.php 。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
<?php
$client
=
new
swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);
$client
->on(
"connect"
,
function
(swoole_client
$cli
) {
$cli
->send(
"GET / HTTP/1.1\r\n\r\n"
);
});
$client
->on(
"receive"
,
function
(swoole_client
$cli
,
$data
){
echo
"Receive: $data"
;
$cli
->send(
str_repeat
(
'A'
, 100).
"\n"
);
sleep(1);
});
$client
->on(
"error"
,
function
(swoole_client
$cli
){
echo
"error\n"
;
});
$client
->on(
"close"
,
function
(swoole_client
$cli
){
echo
"Connection close\n"
;
});
$client
->connect(
'127.0.0.1'
, 9502);
|
打开一个新的窗口命令行执行 。
|
1
|
php client.php
|
执行完后会发现在server.php的窗口就会有信息输出 。
希望本文所述对大家PHP程序设计有所帮助.
原文链接：https://blog.csdn.net/fangdong88/article/details/78050321 。
最后此篇关于php基于 swoole 实现的异步处理任务功能示例的文章就讲到这里了,如果你想了解更多关于php基于 swoole 实现的异步处理任务功能示例的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
25
4
0
我正在构建一个 RCP 应用程序，其中每个季度都会更新功能/插件。因此，如果用户选择自动更新功能/插件，则会下载更新插件的新 jar，但旧插件仍在使用我不再使用的磁盘空间。 我厌倦了删除包含旧 jar
我如何从外部 Controller 功能中调用 Controller 内部的功能，例如电话间隙回调功能 这是 Controller 外部定义的功能 function onDeviceReady()
如果某个功能(例如 MediaSource)可用，我如何使用 Google Dart 检查。 new MediaSource() 抛出一个错误。如何以编程方式检查此类或功能是否存在？有任何想法吗？是否
我正在尝试运行 Azure Orchestrations，突然我开始从 statusQueryGetUri 收到错误: 协调器函数“UploadDocumentOrchestrator”失败:函数“U
我见过 iPhone 上的应用程序，如果在 3.0 上运行，将使用 3.0 功能/API，例如应用内电子邮件编辑器，如果在 2.x 上运行，则不使用这些功能，并退出应用程序以启动邮件相反。 这是怎么做
这是 DB 规范化理论中的一个概念: Third normal form is violated when a non-key field is a fact about another non-ke
如果我定义 #if SOMETHING #endif 而且我还没有在任何地方定义 SOMETHING。 #if 中的代码会编译吗？ 最佳答案 当#if的参数表达式中使用的名称未定义为宏时(在所有其他宏
我刚刚澄清了 A* 路径查找应该如何在两条路径具有相等值的 [情况] 下运行，无论是在计算期间还是在结束时，如果有两条相等的短路径。 例如，我在我的起始节点，我可以扩展到两个可能的节点，但它们都具有相
Java有没有类似下面的东西 宏 一种遍历所有私有(private)字段的方法 类似于 smalltalk symbols 的东西——即用于快速比较静态字符串的东西？ 请注意，我正在尝试为 black
这个程序应该将华氏度转换为摄氏度: #include int main() { float fahrenheit, celsius; int max, min, step;
当打开PC缓存功能后, 软件将采用先进先出的原则排队对示波器采集的每一帧数据, 进行帧缓存。 当发现屏幕中有感兴趣的波形掠过时, 鼠标点击软件的(暂停)按钮, 可以选择回看某一帧的波形
我有一个特殊的(虚拟)函数，我想在沙盒环境中使用它: disable.system.call eval(parse(text = 'model.frame("1 ~ 1")'), envir = e
使用新的 Service 实现，我是否必须为我的所有服务提供一个 Options 方法？ 使用我的所有服务当前使用的旧 ServiceBase 方法，OPTIONS 返回 OK，但没有 Access-
我正在阅读 Fogus 的关于 Clojure 的喜悦的书，在并行编程章节中，我看到了一个函数定义，它肯定想说明一些重要的事情，但我不知道是什么。此外，我看不到这个函数有什么用 - 当我执行时，它什么
我有大量的 C 代码，大部分代码被注释掉和/或 #if 0。当我使用 % 键匹配 if-else 的左括号和右括号时，它也匹配注释掉的代码。 有没有办法或vim插件在匹配括号时不考虑注释掉或#if 0
我有这个功能: map(map(fn x =>[x])) [[],[1],[2,3,4]]; 产生: val it = [[],[[1]],[[2],[3],[4]]] 我不明白这个功能是如何工作的。
我使用 Visual Studio 代码创建了一个函数应用程序，然后发布了它。功能应用程序运行良好。我现在在功能门户中使用代码部署功能(KUDU)并跳过构建。下面是日志 9:55:46 AM
我有一个数据框df: userID Score Task_Alpha Task_Beta Task_Charlie Task_Delta 3108 -8.00 Easy Easy
我真的无法解决这个问题: 我有一个返回数据框的函数。但是，数据框仅打印在我的控制台中，尽管我希望将其存储在工作空间中。我怎样才能做到这一点？ 样本数据: n <- 32640 t <- seq(3*p
有没有办法找出所有可能的激活器命令行选项？ activator -help仅提供最低限度的可用选项/功能列表，但所有好的东西都隐藏起来，即使在 typesafe 网站在线文档中也不可用。 到目前为止，
我是一名优秀的程序员,十分优秀！