`
liu86th
  • 浏览: 114034 次
  • 性别: Icon_minigender_1
社区版块
存档分类
最新评论

基于PHP的消息队列

 
阅读更多
<?php

/* 
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */

error_reporting(E_ALL);
date_default_timezone_set('GMT');
define('ROOT_PATH', __DIR__);

require_once __DIR__ . '/lib/Worker.php';
require_once __DIR__ . '/lib/Job.php';
require_once __DIR__ . '/lib/Queue.php';
require_once __DIR__ . '/lib/Status.php';

//开启一个工作进程
$Worker = new Worker('default');
$Worker->work();

 

分享到:
评论

相关推荐

    ZeroMQ-一个基于内存的消息队列

    zeromq是一个基于内存的消息队列,支持windows,linux和各种平台,支持python,java,php,.net等各种语言。

    PHP消息队列服务php-queue.zip

    php-queue 是 PHP开发的磁盘存储消息队列服务,基于leveldb和swoole ,在4核机器上处理能力可以达到2.5W/s 。leveldb: ...

    Redis延时消息队列基于swoole实现的多进程消费端

    Serve 基于Swoole Server 编写的消息队列消费系统

    php消息队列框架httpsqs

    HTTPSQS(HTTP Simple Queue Service)是一款基于 HTTP GET/POST 协议的轻量级开源简单消息队列服务,使用 Tokyo Cabinet 的 B+Tree Key/Value 数据库来做数据的持久化存储。源代码不超过700行,整个软件不超过900KB...

    Go-Delayer-基于Redis的延迟消息队列中间件

    基于 Redis 的延迟消息队列中间件,采用 Golang 开发,支持 PHP、Golang 等多种语言客户端。

    php基于Redis消息队列实现的消息推送的方法

    在普通的任务脚本中写入push_queue队列要发送消息的目标,并为目标设置一个要推送的内容,永不过期 RedisPushQueue中brpoplpush处理,处理后的值放到temp_queue,主要防止程序崩溃造成推送失败 ...

    RabbitMq消息队列指南.docx

    RabbitMQ是由erlang语言开发,基于AMQP(Advanced Message Queue 高级消息队列协议)协议实现的消息队列,它是一种应用程序之间的通信方法,消息队列在分布式系统开发中应用非常广泛。 MQ 为Message Queue , 消息...

    PHP基于Redis消息队列实现发布微博的方法

    主要介绍了PHP基于Redis消息队列实现发布微博的方法,结合实例形式分析了php+redis数据库的安装、连接、读取、插入等相关操作技巧,需要的朋友可以参考下

    Mega-WeChat:基于Swoole的微信发送模板消息队列服务

    功能特性发送微信模板消息多进程执行发送模板消息接口队列时序性文件消息队列存储基于Swoole高性能网络框架发送消息完成,通知客户端。使用场景对业务上发送模板消息的解耦。即时发送模板消息请求,无需等待微信API...

    PHP实现双向队列

    php实现的基于数组的双向队列的实现,分为两种实现方式,一种是根据数组的key进行进出队列的操作,一种是使用数组自身的性质进行的操作

    php+redis消息队列实现抢购功能

    本文实例为大家分享了php+redis消息队列实现抢购的具体代码,供大家参考,具体内容如下 实现功能: 1. 基于redis队列,防止高并发的超卖 2. 基于mysql的事务加排它锁,防止高并发的超卖 基于redis队列工作流程:...

    httpsqs_client --轻量级简单队列服务HTTPSQS

     ● 可以实时查看队列状态(入队列位置、出队列位置、未读队列数量、最大队列数量)。  ● 可以查看指定队列ID(队列点)的内容,包括未出、已出的队列内容。  ● 查看队列内容时,支持多字符集编码。  ● 源...

    PHP队列原理及基于队列的写文件案例

    本文实例讲述了PHP队列原理及基于队列的写文件案例。分享给大家供大家参考,具体如下: 队列是一种线性表,按照先进先出的原则进行的: 入队: 出队: PHP实现队列:第一个元素作为队头,最后一个元素作为队尾 &...

    PHP实现基于Redis的MessageQueue队列封装操作示例

    本文实例讲述了PHP实现基于Redis的MessageQueue队列封装操作。分享给大家供大家参考,具体如下: Redis的链表List可以用来...基于Redis的PHP消息队列封装 &lt;?php /** * Created by PhpStorm. * User: huyanping *

    SixMQ 是一款 PHP 消息队列系统,基于 imi 框架开发的,运行在 PHP + Swoole 环境下。.zip

    软件开发设计:应用软件开发、系统...云计算与大数据:包括云计算平台、大数据分析、人工智能、机器学习等,云计算是一种基于互联网的计算方式,通过这种方式,共享的软硬件资源和信息可以按需提供给计算机和其他设备。

    使用phpfpm作为一个简单的内置异步队列

    使用php-fpm作为一个简单的内置异步队列。 基于可互操作的队列接口Queue Interop。

Global site tag (gtag.js) - Google Analytics