rabbitmq 相关方法
//连接$conn_args = array( 'host'=>'127.0.0.1' , 'port'=> '5672', 'login'=>'guest' , 'password'=> 'guest'); $conn = new AMQPConnection($conn_args);
//通道方法$channel = new AMQPChannel($conn); $channel->basicRecover(requeue:bool=true);
$channel->commitTransaction(); $channel->getPrefetchCount(); $channel->getChannelId(); $channel->getConnection(); $channel->getPrefetchSize(); $channel->isConnected(); $channel->qos(size:int,count:int); $channel->rollbackTransaction(); $channel->setPrefetchCount(count:int); $channel->setPrefetchSize(size:int);
$channel->startTransaction(); //交换机方法
$ex = new AMQPExchange($channel); $ex->bind(exchange_name:string,[route_key:string=''],[arguments:array=array()]); $ex->declareExchange();//1.2.0 后由declare()改为declareExchange(); $ex->delete([exchangeName=null],[flags:int=AMQP_NOPARAM]);
$ex->getArgument(key:string); $ex->getArguments(); $ex->getChannel(); $ex->getConnection(); $ex->getFlags(); $ex->getName(); $ex->getType(); $ex->publish(message:string,[flags:int=AMQP_NOPARAM],[attributes:array=array()]); $ex->setArgument(key:strig,value:int|string); $ex->setArguments(arguments:array); $ex->setName(exchange_name:string); $ex->setFlags(flags:int); $ex->unbind(exchange_name:string,[route_key:string=''],[arguments:array=array()]); //队列方法
$q = new AMQPQueue($channel); $q->ack(delivery_tag:string,[flags:int=AMQP_NOPARAM]); $q->bind(); $q->cancel(consumer_tag:string=''); $q->consume([callback:callable|null=null],[flags:int=AMQP_NOPARAM],[consumerTag=null]); $q->declareQueue(); $q->delete([flags:int=AMQP_NOPARAM]); $q->get([flags:int=AMQP_NOPARAM]); $q->getArgument(key:string); $q->getArguments(); $q->getChannel(); $q->getConnection(); $q->getFlags(); $q->getName(); $q->nack(delivery_tag:string,[flags:int=AMQP_NOPARAM]); $q->purge(); $q->reject(delivery_tag:string,[flags:int=AMQP_NOPARAM]); $q->setArgument(key:string,vaule); $q->setArguments(arguments:array); $q->setFlags(flags:int); $q->setName(queue_name:string); $q->unbind(exchange_name:string,[route_key:string=''],[arguments:array=array()]);
rabbitmq 相关方法相关推荐
- RabbitMQ—队列迁移插件shovel的使用
原文作者:xiaoliuliu2050 原文地址:rabbitmq 学习 之 shovel 插件使用(24) 目录 一.shovel插件基本功能 二.shovel 的使用场景 三.针对 static ...
- RabbitMQ快速入门及实例演示
RabbitMQ 先做起来,再去想其他. 1.MQ 消息队列概念 MQ(message queue)消息队列,FIFO先入先出.对服务器的请求先加入到消息队列中,再由消息队列来进行请求的分发. 还是一 ...
- RabbitMQ系列笔记封装篇
导语 在阅读本篇笔记时,如果你还不熟悉RabbitMQ,请查看公众号中关于RabbitMQ系列笔记相关文章,如果你已经熟悉了,还请在本篇文章多多指教.本文使用go mod进行获取相关包,使用Go1.1 ...
- RabbitMQ实战指南笔记
目录 第1章 RabbitMQ简介 1.1 什么是消息中间件 1.2 消息中间件的作用 1.3 RabbitMQ起源 1.4 RabbitMQ的安装及简单实用 第2章 RabbitMQ入门 2.1 概 ...
- 【rabbitMQ】01 全面理解rabbitMQ
随着用户流量的快速增长,由于传统应用在系统接口和服务处理层面仍然沿用高耦合和同步的处理模式,导致接口由于线程阻塞而延长了整体响应时间,即所谓的高延迟,为解决这个问题使用了rabbitMQ. Rabbi ...
- RabbitMQ——入门介绍
目录 1.消息队列 1.1.MQ 的相关概念 1.1.1.什么是 MQ 1.1.2.为什么要用 MQ 1.1.3.MQ 的分类 1.1.4.MQ 的选择 1.2.RabbitMQ 1.2.1.Rabb ...
- SpringBoot整合RabbitMQ(包含生产者和消费者)
生产者 创建一个SpringBoot项目springboot-producer,作为RabbitMQ的生产者. 在pom文件中引入相关的依赖坐标 <dependency><group ...
- rabbitmq 学习 之shovel 插件使用(22)
转载自 https://yq.aliyun.com/articles/41807 为了方便工作中使用,对 RabbitMQ 的[Shovel]文档进行了翻译,鉴于自己水平有限,翻译中难免有纰漏产生,如 ...
- RabbitMQ 入门系列(11)— RabbitMQ 常用的工作模式(simple模式、work模式、publish/subscribe模式、routing模式、topic模式)
1. simple 模式 simple 模式是最简单最常用的模式 2. work 模式 work 模式有多个消费者 消息产生者将消息放入队列.生产者系统不需知道哪一个任务执行系统在空闲,直接将任务扔到 ...
最新文章
- JS中的offsetWidth, clientWidth, scrollWidth, innerWidth, outerWidth, pageXOffset
- 大学生计算机基础excel视频,大学生计算机基础Excel.doc
- Pythorch使用总览
- 【JavaWeb】Access restriction The type is not accessible due to restriction on required library
- java 保存inputstream_java如何将一个InputStream写入文件啊?
- 4.WCF事务【Transaction】
- Linux pwd命令:显示当前路径
- Java 函数引用 替代方案
- Qt TCP协议 传输简单字符串实例
- HDU1754 —— I Hate It 线段树 单点修改及区间最大值
- 求解偏微分方程开源有限元软件deal.II学习--Step 4
- memcached java api_Memcached Java Client API详解
- set+线段树 Codeforces Round #305 (Div. 2) D. Mike and Feet
- 小额批量支付系统可以完成跨行资金清算吗_今天,你转账了吗?带你看懂央行小额批量支付系统...
- 一种人机友好的视频压缩方案(HMFVC)
- 【简单远程控制】 Metasploit应用
- 卸载程序时遇到“请等待当前程序完成卸载或更改”
- 【opencv学习笔记】第五篇:访问图像中像素的三种方式、ROI区域图像叠加和图像混合
- HTTP(一)HTTP响应的过程
- 考研计算机专业总分255,计算机考研谁见过总分最高分是多少啊?