<div dir="ltr">Great! but miss some other protocol (ack/publish etc..)<br>:-)<br></div><div class="gmail_extra"><br clear="all"><div>--<div><div>smallfish <a href="http://chenxiaoyu.org" target="_blank">http://chenxiaoyu.org</a></div>
</div></div>
<br><br><div class="gmail_quote">On Thu, May 30, 2013 at 9:45 PM, Rohit Yadav <span dir="ltr"><<a href="mailto:rohit.yadav@wingify.com" target="_blank">rohit.yadav@wingify.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
<div dir="ltr"><div>Hi,<br><br></div><div>I started working on implementing a client library for RabbitMQ based on STOMP 1.2 protocol, I'm sharing the initial buggy version [1] with the community for feedback, suggestions and review.<br>
<br></div><div>For the initial version I've implemented only authentication and publishing using receipts. I'll blog about this work with some history and background soon [2].<br></div><div><br></div><div>To test this library I wrote a load testing tool in golang which would run concurrent HTTP requests to an Openresty server. A handler runs Lua code for that request and uses the resty-rabbitmq library to sanitize, serialize and publish data to RabbitMQ's STOMP adapter.<br>
<br></div><div>With a noncurrent load test of total 1M requests, using the library a producer (in /example/) was able to publish all the messages to the broker without any errors. But in case of
concurrent connections, I frequently got timeout errors or writing to
closed socket errors. <br><br>How may I make publishing fault tolerant and avoid deduplicating messages in concurrent environment by correctly implementing states and reuse sockets using cosocket api pool? I set keepalive timeout on the cosocket tcp sock to 0 (no timeout as per wiki) and I saw exponential increase in socket consumed via the RabbitMQ management web interface, for a load of 100k requests, I saw fluctuations between 200-1200 consumed sockets with a lot of socket errors.<br>
<br>Ideas, flames? Thanks.<br><br>[1] <a href="https://github.com/wingify/lua-resty-rabbitmq" target="_blank">https://github.com/wingify/lua-resty-rabbitmq</a><br>[2] <a href="http://engineering.wingify.com/" target="_blank">http://engineering.wingify.com/</a><br>
<br></div><div>Regards,<br></div><div>Rohit Yadav</div></div><span class="HOEnZb"><font color="#888888">
<p></p>
-- <br>
-- <br>
�ʼ������б�“openresty”,ר���ڼ�������!<br>
����: �뷢�հ��ʼ��� <a href="mailto:openresty%2Bsubscribe@googlegroups.com" target="_blank">openresty+subscribe@googlegroups.com</a><br>
����: �뷢�ʼ��� <a href="mailto:openresty@googlegroups.com" target="_blank">openresty@googlegroups.com</a><br>
�˶�: �뷢�ʼ��� <a href="mailto:openresty%2Bunsubscribe@googlegroups.com" target="_blank">openresty+unsubscribe@googlegroups.com</a><br>
�鵵: <a href="http://groups.google.com/group/openresty" target="_blank">http://groups.google.com/group/openresty</a><br>
����: <a href="http://openresty.org/" target="_blank">http://openresty.org/</a><br>
�ֿ�: <a href="https://github.com/agentzh/ngx_openresty" target="_blank">https://github.com/agentzh/ngx_openresty</a><br>
�̳�: <a href="http://openresty.org/download/agentzh-nginx-tutorials-zhcn.html" target="_blank">http://openresty.org/download/agentzh-nginx-tutorials-zhcn.html</a><br>
<br>
<br>
</font></span></blockquote></div><br></div>