php如何防止消息被篡改,php如何用libevent处理rabbitmq发来的消息，防止消息丢失或者人为的中断导致消息没有被处理完整...

之前是用官方提供的方法来处理的

$channel->basic_consume('hello', '', false, true, false, false, $callback);

while(count($channel->callbacks)) {

$channel->wait();

}

发现中断程序的时候每个消息没有被完全处理完，比如拿到消息还没有处理完入库就被中断了。

后来打算用libevent 据说在事件处理中，除非强制kill掉，不然事件会处理完再中断，但是以下代码还是不断报错；

$this->connection = new AMQPStreamConnection($config['host'], $config['port'], $config['user'], $config['password'], $config['vhost']);

$this->channel = $this->connection->channel();;

$this->channel->queue_declare($queue, false, true, false, false);

// $this->channel->basic_consume($queue, '', false, true, false, false, function ($msg) {

// set_trace_prefix(md5($msg->body . time()));

// trace('receive msg:' . $msg->body);

// trace('done');

// });

$ch = $this->channel;

$fd = $this->connection->getSocket();

Worker::$globalEvent->add($fd, EventInterface::EV_READ, function ($fd) use ($queue, $ch){

$msg = $ch->basic_get($queue, true);

print_r($msg);

print("get a messge:\n");

});

php如何防止消息被篡改,php如何用libevent处理rabbitmq发来的消息，防止消息丢失或者人为的中断导致消息没有被处理完整...相关推荐

各个MQ消息队列介绍以及区别比较（RabbitMq ActiveMQ、ZeroMQ、Kafka）
首先,MQ其实就是消息队列,队列我们可以理解为管道,以管道的方式做消息传递. 在本篇博客中,我们先来简单学习一下几种MQ,之后对他们进行对比. ActiveMQ.RabbitMQ.kafka.Rock ...
RocketMQ如何保证消息不丢失? 如何快速处理积压消息？
文章目录 1. 哪些环节会有丢消息的可能? 2. 消息生产阶段如何保证消息不丢失 2.1 同步发送 2.2 采用事务消息 3. Broker如何保证接收到的消息不会丢失 4. 消费者如何确保拉取到的消 ...
activemq消息丢失_基于Redis实现消息队列的典型方案
基于Redis实现消息队列典型方案 1 概述 2 基于List的 LPUSH+BRPOP 的实现 3 PUB/SUB,订阅/发布模式 4 基于SortedSet有序集合的实现 5 基于 Stream ...
java给朋友发微信_微信api接口，给微信好友收发消息
微信api接口,给微信好友收发消息 /** * 给微信好友发消息 * @author wechatno:tangjinjinwx * @blog http://www.wlkankan.cn */ @ ...
【消息中间件MQ系列】消息队列之ActiveMQ、RocketMQ、RabbitMQ、Kafka不得不说的秘密
热门系列: [消息中间件MQ系列]RabbitMQ安装与使用,并与SpringBoot整合程序人生,精彩抢先看目录 1.消息队列/消息中间件介绍 1.1 消息中间件是什么 1.1.1 消息中间件的 ...
RabbitMQ 服务异步通信 -- 入门案例（消息预存机制）、SpringAMQP、发布订阅模式（FanoutExchange、DirectExchange、TopicExchange）、消息转换器
文章目录 1. 入门案例 2. 完成官方Demo中的hello world案例 2.1 创建1个工程,2个模块 2.1.1 父工程的依赖,子工程不需要导入额外的依赖 2.1.2 配置子工程的配置文件( ...
消息队列超详解（以RabbitMQ和Kafka为例，为何使用消息队列、优缺点、高可用性、问题解决）
消息队列超详解(以RabbitMQ和Kafka为例) 为什么要用消息队列这个东西? 先说一下消息队列的常见使用场景吧,其实场景有很多,但是比较核心的有3个:解耦.异步.削峰. 解耦:现场画个图来说明一 ...
怎么做一个定时消息提醒_如何用Nodejs编写一个定时消息提醒应用？
背景: 同事告诉我最近一段时间每天上班长时间盯着屏幕工作经常眼睛疼,问我有没有好用定时提醒功能.我受到启发,决定用nodejs来实现一个定时提醒应用. 需求分析: 同事是个程序员,熟悉命令行操作,这样 ...
消息队列系列（三）：.Rabbitmq Trace的使用
一.什么是Trace Trace是Rabbitmq用于记录每一次发送的消息,方便使用Rabbitmq的开发者调试.排错.可通过插件形式提供可视化界面二.Trace实现概况 1.Trace启动后会自 ...

php如何防止消息被篡改,php如何用libevent处理rabbitmq发来的消息，防止消息丢失或者人为的中断导致消息没有被处理完整...

php如何防止消息被篡改,php如何用libevent处理rabbitmq发来的消息，防止消息丢失或者人为的中断导致消息没有被处理完整...相关推荐

最新文章

热门文章