redis作为消息队列实现代码

ゞ浴缸里的玫瑰 2022-07-19 00:17 137阅读 0赞

这里只是简单实现下redis消息队列，主要了解下这个思路  
要把消息队列最好，还需考虑可靠消费、可靠发布、持久化、路由匹配、队列监控、负载均衡。。。  
大都用专业的消息队列系统如rabbitmq，我们公司用的就是这个

producer.php生产者者代码

<?php
    $redis = new Redis();
    $redis->connect('192.168.1.198',7000);
    while(true){ 
    	try{ 
    		$value = 'value_'.date('Y-m-d H:i:s'); 
    		$redis->lpush('key1',$value);//生成消息
    		sleep(rand()%3); 
    		echo $value."\n"; 
    	}catch(Exception $e){ 
    		echo $e->getMessage()."\n"; 
    	} 
    } 
    ?>

consumer.php消费者代码

<?php
    $redis = new Redis();
    $redis->connect('192.168.1.198',7000);
    while(true){ 
    	try{ 
    		$value=$redis->lpop('key1')."\n"; 
    		file_put_contents('val.txt',$value,FILE_APPEND);//将获取到的消息存入val.txt
    	}catch(Exception $e){ 
    		echo $e->getMessage()."\n"; 
    	} 
    	sleep(rand()%3); 
    }
    ?>

分别命令行执行生产者和消费者  
\[root@localhost redis\]\# php producer.php  
value\_2016-08-06 20:22:57  
value\_2016-08-06 20:22:58  
value\_2016-08-06 20:22:59  
value\_2016-08-06 20:23:01  
value\_2016-08-06 20:23:03  
...

\[root@localhost redis\]\# php consumer.php

![Center][]

[Center]: /images/20220718/af23e7d3505a4eea9ca6cf3caea0ae6b.png

发表评论取消回复

表情：

评论列表（有 0 条评论，137人围观）

还没有评论，来说两句吧...

相关阅读

相关 Redis实现消息队列

7、Redis消息队列 7.1 Redis消息队列-认识消息队列什么是消息队列：字面意思就是存放消息的队列。最简单的消息队列模型包括3个角色：消息队列：

妖狐艹你老母/ 2024年03月27日 11:17/ 0 赞/ 108 阅读

相关 Redis实现消息队列-代码实现2

Redis实现消息队列-代码实现一、前言二、代码项目结构图： ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10

系统管理员/ 2023年10月10日 12:52/ 0 赞/ 63 阅读

相关 Redis实现消息队列

前言 Redis可以通过发布订阅模式、轮询机制实现消息队列。由于没有消息持久化与 ACK 的保证，所以，Redis 的发布订阅功能并不可靠。这也就导致了它的应用场景很

向右看齐/ 2023年10月01日 12:03/ 0 赞/ 31 阅读

相关 PHP + Redis 实现消息队列

Redis做消息队列的好处在于它的轻量级，高并发，延迟敏感，应用场景有即时数据分析、秒杀计数器、缓存等 Redis做消息队列待解决的问题：　　1、消息的可靠性：没有相

太过爱你忘了你带给我的痛/ 2023年08月17日 16:14/ 0 赞/ 142 阅读

相关 redis实现消息队列

1. 实现方式队列模式发布订阅模式 2. 原理原理很简单，用的redis的List类型，list是按照插入的顺序排序的字符串链表。和数据结构中的普通链表类似，可

客官°小女子只卖身不卖艺/ 2023年03月13日 06:42/ 0 赞/ 19 阅读

相关 redis消息队列PHP,如何基于redis实现消息队列

![f1d792136aeb6b31e67741f0777acb37.png][] 消息队列，Message Queue，常用于解决并发系统中的资源一致性问题，提升峰值的处理

以你之姓@/ 2022年11月12日 09:53/ 0 赞/ 280 阅读

相关 redis作为消息队列实现代码

这里只是简单实现下redis消息队列，主要了解下这个思路要把消息队列最好，还需考虑可靠消费、可靠发布、持久化、路由匹配、队列监控、负载均衡。。。大都用专业的消息队列

ゞ浴缸里的玫瑰/ 2022年07月19日 00:17/ 0 赞/ 138 阅读

相关 Redis实现简单消息队列

Redis实现简单消息队列 [![144][]][144 1] 作者 [人世间][144 1] 关注 2015.04.28 14:22\ 字数 1169 阅

旧城等待，/ 2022年06月17日 02:51/ 0 赞/ 308 阅读

相关 redis_消息队列

Redis的消息是topic（广播）机制。感觉实用性不大，因为消息有专门的消息技术，如kafka,mq。在这里简单做个笔记。发布消息：publish 名称 "内容" 订阅

╰半橙微兮°/ 2022年05月25日 08:55/ 0 赞/ 252 阅读

相关 Redis实现异步消息队列，延时队列

异步消息队列 Redis中的 list（列表）实现异步消息队列，使用rpush / lpush 操作插入队列消息，使用 lpop 和 rpop 来出队消息。

╰+哭是因爲堅強的太久メ/ 2022年03月02日 08:44/ 0 赞/ 443 阅读