【swoole】结合swoole 和 nsq 的实际应用

AdolphLWQ 发布于2019-07-01 12:51 / 2407人阅读

摘要：并且注册回调函数。在重写的回调函数中，实现了的订阅功能消息的处理简单封装了重复消息的判断没有消费消息的重新投递引入就是构造方法引入的实例化同时，重写的方法。所以当执行脚本的时候，也就是启动了对应的服务。当然更好的是使用协程。

集合 swoole 的框架设计

为了减少理解度，我尽量的从源头开始引入

1. nsq

案例中是使用 swoole 结合一个php 框架实现的是 NSQ 订阅功能。

启动命令:

sudo bash /www/webserver/bin/swoole.sh start nsq adminexport

解释上面一个指令，使用 bash 执行一个项目中的脚本。

start 对应启动命令
nsq ：代表对应使用NSQ 服务
adminexport ：对应的是NSQ 的topic

脚本的本质，通过框架的入口文件，根据传参，进入到的不同的消息中间件，及对应的服务

2. php 订阅

AdminexportService 继承封装好的 SwooleService。在init方法中，初始化 swoole服务。并且注册回调函数。

AdminexportService 在重写的 swooleWorkerStart 回调函数中，实现了NSQ 的订阅功能

NSQ 消息的处理

简单封装了重复消息的判断

requeue 没有消费消息的重新投递

3. 引入 swoole

就是构造方法引入 swoole 的实例化
同时，重写 workerStart 的方法。

所以当执行脚本的时候，也就是启动了对应的swoole 服务。启动了订阅者的客户端。
不断的消费来自nsq topic 的消息

看吧，swoole 其实也很简单。把它当做一个工具类，拿来用就可以了。在实现的时候引入它，通过 WorkerStart 处理分发的消息即可。

当然更好的是使用协程。
另外吹一波，协程就是厉害

云服务器 GPU云服务器 Swoole swoole+websocket php_swoole think-swoole

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/31619.html

【swoole 学习笔记】swoole 真的优秀一个框架

摘要：所以，我感觉学习，需要一个引导。学习参考链接喵星球特别厉害的一个官网的几个框架文档优势先看一下的结构设计的应用场景的设计项目中引入一个简易的具体参考一篇文章，集合和的简易实例项目中引入结合致敬前期学完了操作系统，特别是知道了进程，线程调度的问题。回来看，发现了很多细节。第三次看文档，最初经一个高手朋友的介绍，看swoole，说文档写的贼好。但是看的时候，也是很一头雾水，只知道把de...

13651657101 2019-07-01 12:51 评论0 收藏0
【天赢金创】PHP7与Swoole

摘要：但在密集计算方面比等静态编译语言差几十倍甚至上百倍。一使用栈内存在引擎和扩展中，经常要创建一个的变量，底层就是一个指针。代码中创建的变量也进行了优化，直接在栈内存上预分配。应用层与底层在错误抛出的方式全部统一为异常。原文：http://rango.swoole.com/archives/440最近PHP官方终于发布了传说中的PHP7，虽然只是alpha版。PHP7号称是新一代的PHP...

MingjunYang 2019-06-27 11:34 评论0 收藏0
Swoole学习手记（一）初识Swoole

摘要：目录初识创建服务器上创建服务器下异步任务持续更新中。。。参加工作有一段时间了，偶尔会听到，对我这种小白粗略看下文档都会觉得很牛逼。个人理解就是解决这样应用场景的。目录初识Swoole 创建服务器(上) 创建服务器(下) 异步任务task 持续更新中。。。参加工作有一段时间了，偶尔会听到swoole，对我这种PHP小白粗略看下文档都会觉得很牛逼。由于学习成本比较高，自身对网络异...

yeyan1996 2019-06-28 18:47 评论0 收藏0
PHP并发IO编程之路

摘要：下文如无特殊声明将使用进程同时表示进程线程。收到数据后服务器程序进行处理然后使用向客户端发送响应。现在各种高并发异步的服务器程序都是基于实现的，比如。并发 IO 问题一直是服务器端编程中的技术难题，从最早的同步阻塞直接 Fork 进程，到 Worker 进程池/线程池，到现在的异步IO、协程。PHP 程序员因为有强大的 LAMP 框架，对这类底层方面的知识知之甚少，本文目的就是详细介...

Riddler 2019-07-01 12:39 评论0 收藏0
swoole入门4-初识swoole

摘要：当某种网络事件发生时，会回调用户设置的指定回调函数。承担了底层网络事件的监听及各种底层事件处理，当收到请求时，会触发事件提醒，然后将控制权转交预先注册的事件回调函数，来进行后续的处理。请求到来时创建，请求结束后销毁。运行流程图 showImg(https://segmentfault.com/img/remote/1460000017207791);showImg(https://s...

forsigner 2019-07-01 11:00 评论0 收藏0