¿ªÔ´Èí¼þ-php-nsq NSQµÄPHP¿Í»§¶Ë

php-nsq

php-nsq ÊÇnsqµÄphp¿Í»§¶Ë£¬²ÉÓÃcÀ©Õ¹±àд£¬ÐÔÄܺÍÎȶ¨ÐÔ¡£

°²×° :

ÇëÌáÇ°°²×°libevent

Dependencies:?libevent??(apt-get?install?libevent-dev?,yum?install?libevent-devel)

1.?sudo?phpize
2.?./configure?
3.?make??
4.?make?install??

add?in?your?php.ini:

extension?=?nsq.so;

?pubÀý×Ó:

$nsqdAddr?=?array(
????"127.0.0.1:4150",
????"127.0.0.1:4154"
);

$nsq?=?new?Nsq();
$isTrue?=?$nsq->connectNsqd($nsqdAddr);

for($i?=?0;?$i?publish("test",?"nihao");
}
$nsq->closeNsqdConnection();

//?Deferred?publish?
//function?:?deferredPublish(string?topic,string?message,?int?millisecond);?
//millisecond?default?:?[0?connectNsqd($nsqdAddr);
for($i?=?0;?$i?deferredPublish("test",?"message?daly",?3000);?
}
$deferred->closeNsqdConnection();

?subÀý×Ó:

?"test",
????"channel"?=>?"struggle",
????"rdy"?=>?2,????????????????//optional?,?default?1
????"connect_num"?=>?1,????????//optional?,?default?1???
????"retry_delay_time"?=>?5000,??//optional,?default?0?,?if?run?callback?failed,?after?5000?msec,?message?will?be?retried
????"auto_finish"?=>?true,?//default?true
);

$nsq->subscribe($nsq_lookupd,?$config,?function($msg,$bev){?

????echo?$msg->payload;
????echo?$msg->attempts;
????echo?$msg->message_id;
????echo?$msg->timestamp;


});

Nsq Àà·½·¨£º

• connectNsqd($nsqdAddrArr)?
  pubµÄʱºòÁ¬½Ónsq£¬ÄãÒ²¿ÉÒÔÀûÓô˺¯Êý×ö½¡¿µ¼ì²é

• closeNsqdConnection()?
  ¹Ø±ÕnsqµÄÁ¬½Ó

• publish($topic,$msg)?
  ÏûÏ¢·¢ËÍ

• deferredPublish($topic,$msg,$msec)?
  ÑÓ³ÙÏûÏ¢·¢ËÍ

• subscribe($nsq_lookupd,$config,$callback)?
  ÏûÏ¢¶©ÔÄ

Message Àà·½·¨ÓëÊôÐÔ£º

• timestamp?
  ÏûϢʱ¼ä´Á

• attempts?
  ÏûÏ¢µÄÖØÊÔ´ÎÊý£¬£¨´Ó1¿ªÊ¼£©

• message_id?
  ÏûÏ¢id?

• payload?
  ÏûÏ¢ÄÚÈÝ

• finish($bev,$msg->message_id)?
  Ö÷¶¯µÄ ackÏûÏ¢·½·¨

• touch($bev,$msg->message_id)?
  Èç¹ûÄãÏûÏ¢Ö´ÐÐÌ«³¤£¬¿ÉÒÔÀûÓôκ¯Êý¸æÖªnsq Ä㻹»î×Å£¬Ò»°ãÓÃÓÚÖ´ÐÐƵÂʱȽϹæÂɵij¡¾°¡£

Tips :

1.Èç¹ûcallbackÄÚÐèÒªÍⲿ±äÁ¿£¬¿ÉÒÔ²ÉÓÃÒÔÏÂuseµÄд·¨:

$nsq->subscribe($nsq_lookupd,?$config,?function($msg,$bev)?use?($you_variable){?

????echo?$msg->payload;
????echo?$msg->attempts;
????echo?$msg->message_id;
????echo?$msg->timestamp;


});

?2.ÏûÏ¢ÖØÊÔ£¬Ö»ÒªÅ×Òì³£¾Í¿ÉÒÔ£¬ÇмDz»ÒªÏÝÈëËÀÑ­»·£¬³¬¹ý×Ô¼º¾õµÃ¿ÉÒԵĴÎÊý Òªreturn:

subscribe($nsq_lookupd,?$config,?function($msg){?
????try{
????????echo?$msg->payload?.?"?"?.?"attempts:".$msg->attempts."\n";
????????//do?something
????}catch(Exception?$e){

????????if($msg->attempts?getMessage();
????????????return;
????????}
????}

});

3.Èç¹ûÄãÏëÔö¼Ó ¿Í»§¶ËµÄÐÄÌøʱ¼äÓëÏûÏ¢µÄ³¬Ê±Ê±¼ä £º

?µÚÒ»²½?ÔÚnsqdÆô¶¯Ê±Òª¼ÓÈëÏà¹Ø²ÎÊý£¬Õâ¸ö²ÎÊýÊÇ×î´óµÄÏÞÖÆ£¬±ÈÈç--max-heartbeat-interval=1m30s?ÐÄÌøʱ¼ä×î´ó²»Äܳ¬¹ý1·Ö30Ã룺

??????nsqd?--lookupd-tcp-address=127.0.0.1:4160?--max-heartbeat-interval=1m30s?--msg-timeout=10m30s

µÚ¶þ²½??ÒòΪµÚÒ»²½ÊÇÖ¸¶¨×î´óʱ¼ä£¬ËùÒÔ»¹ÐèÒªµÚ¶þ²½ÔÚ¿Í»§¶ËÖ¸¶¨ËùÐèÒªµÄÖµ?¾ßÌåÇë¿´?exampleĿ¼ÖеÄidentify¿ªÍ·µÄÎļþÀý×Ó¡£

4.Èç¹ûÄãÏëÔöÇ¿Ïû·ÑÄÜÁ¦£¬¿ÉÒÔ¼Ó´órdy²ÎÊý

5.Äã¿ÉÒÔÓÃsupervisor¹ÜÀí£¬µ«ÊÇÒòΪÊǶà½ø³ÌÏû·Ñ£¬ÄãÐèÒªÔÚsupervisor jobµÄÅäÖÃÎļþ?Ìí¼Ó:?

????stopasgroup=true
????killasgroup=true

Changes

• 3.0

  • ÐÞ¸´Òòlibevent ³¬¹ý4096ÏûÏ¢±»½Ø¶ÏÎÊÌâ

  • Ôö¼ÓidentifyÖ¸ÁÄÜ£¬¿ÉÒÔÔö¼Ó¿Í»§¶ËÐÄÌøʱ¼ä Óë ÏûÏ¢³¬Ê±Ê±¼ä

• 2.4.0

  • ÐÞ¸´ pub bug

  • ÐÞ¸´ sub coredump

  • ÐÞ¸²¸Ç touch bug

  • Ôö¼ÓµÈ´ý£¬µ±¸Õ³õʼ»¯µÄtopicûÏûϢʱ

• 2.3.1

  • pubÖ§³ÖÓòÃû

  • ÐÞ¸´ pub coredump