>php教程 >php手册 >Java获取php端放入rabbitmq内的消息

Java获取php端放入rabbitmq内的消息

WBOY
WBOY원래의
2016-06-06 19:57:021271검색

欢迎进入Java社区论坛,与200万技术人员互动交流 >>进入 // get方式主动消费 GetResponse res=channel.basicGet(queue_name, false); if (res != null res.getMessageCount() = 0) { System.out.println(res.getMessageCount()); String message

欢迎进入Java社区论坛,与200万技术人员互动交流 >>进入

 

  // get方式主动消费

  GetResponse res=channel.basicGet(queue_name, false);

  if (res != null && res.getMessageCount() >= 0)

  {

  System.out.println(res.getMessageCount());

  String message = "";

  message = new String(res.getBody());

  channel.basicAck(res.getEnvelope()。getDeliveryTag(), false);

  System.out.println(" [x] Received '" + message + "'");

  }

  else

  {

  System.out.println("消息队列中没有可消费的信息!");

  break;

  }

  }

  channel.close();

  connection.close();

  } catch (Exception e) {

  e.printStackTrace();

  }

  }

  }

  在开发的过程中,主要报的异常是:

  1.创建交换机和消息队列时,设置的属性和消息产生端的php代码设置的不一样,导致不匹配和一直重写属性

  2.在调用时一直没有确定到底是用basicConsume的消费模式还是basicGet消费模式(前者带有监控效果,后者没有,不知道是不是因为一者有跳出while循环,一者没有的原因)

  [1] [2] 

Java获取php端放入rabbitmq内的消息

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.