Alexandre
PHPПенсионер
вот почему я стараюсь не комментировать на русском
-~{}~ 01.05.09 20:47:
жаль что форум не смог отобразить японский
PHP:
//客户端
void client(){
carrot::Connection c1(HOST,AMQP_PORT);
carrot::Channel* ch=c1.open_channel();
//消息选择器，把这个选择器设置为消息properties的reply_to字段，服务器端才会把
// 应答消息发回给这个客户端
string my_selector="example_client";
MessageProperties mp;
//设置message_properties的reply_to,服务器端接受到后把此字段放入返回消息的 correlation_id
mp.reply_to(my_selector);
ch->publish(GROUP_EX,GROUP_QS,"hahahahaha",10,mp);
//get的第一个参数是 "队列名#选择器"
Message response=ch->get(string(GROUP_QC)+"#"+my_selector,true);
while(response.empty()){
/*
* 这里需要一个超时处理，因为Channel#get函数总是立即返回，
* 当队列里无消息时get返回的Message为空(Message#empty()返回true)
* 或者用consume方式订阅此队列，即可不用超时处理
*/
response=ch->get(string(GROUP_QC)+"#"+my_selector,true);
}
string result=string(response.body().second,response.body().first);
std::cout<<"response : " << result << std::endl;
pause();
}жаль что форум не смог отобразить японский
