zoukankan      html  css  js  c++  java
  • 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()]);




  • 相关阅读:
    VS的代码分析工具
    时间管理-SMART原则
    时间管理-该怎样进行时间管理
    ASP.NET Identity V2
    SQL Server 事务隔离级别的查看及更改
    GAC(Global Assembly Cache)注册/卸载 dll
    基于小米即时消息云服务(MIMC)的Web IM
    Spring Boot MyBatis配置多种数据库
    解决easyui combobox赋值boolean类型的值时,经常出现的内容显示的value而不是text的bug
    thymeleaf-extras-db 0.0.1发布,select标签加载数据的新姿势
  • 原文地址:https://www.cnblogs.com/grimm/p/5729571.html
Copyright © 2011-2022 走看看