RSocket | RSocket
Why RSocket?RSocket provides a protocol for Reactive Streams semantics between client-server, and server-server communication. Motivations What is RSocket?RSocket is a binary protocol for use on byte stream transports such as TCP, WebSockets, and Aeron. Protocol Spec How do I use RSocket?RSocket is intended to be consumed via one of the various implementation libraries which implement the RSocket
Setting a Socket Connection Timeout in Ruby
Ruby’s default socket connection timeout can be too long in many situations (e.g. when feedback needs to be provided to a user that has just entered a host name to connect to). On my Mountain Lion laptop, it takes close to 75 seconds for it to fail to connect to an unused IP address: irb> require 'benchmark' irb> puts Benchmark.measure { TCPSocket.new("192.178.1.2", 9090) rescue nil } 0.000000 0.0
Socket Timeouts in Ruby | Mike Perham
2009-03-15 One of Ruby’s weaknesses is its poor networking performance. Much of that has to do with the net/http implementation, which uses Ruby’s awful Timeout library. The issues with Timeout are well documented. SystemTimer provides a reliable alternative that also performs better. However I started today wondering if there was a better way. Enabling timeouts has a huge performance hit on my me
GitHub - fastos/fastsocket: Fastsocket is a highly scalable socket and its underlying networking implementation of Linux kernel. With the straight linear scalability, Fastsocket can provide extremely good performance in multicore machines. In addition, it
With a rapid growth of NIC bandwidth and CPU cores on one single machine, a scalable TCP network stack is performance-critical. However, stock Linux kernel does not scale well when CPU core number is above 4. It is even worse that the throughput could collapse when there are more than 12 CPU cores. Fastsocket is a scalable kernel TCP socket implementation and achieves a straight linear performance
Linuxã§TCP_DEFER_ACCEPTãŒæœ‰åŠ¹ã§ã‚‚accept後readã§ããªã„ç†ç”±
listen()ã®backlogãŒä¸è¶³ã—ãŸéš›ã®TCP_DEFER_ACCEPTã®å‹•ä½œã«ã¤ã„㦠- blog.nomadscafe.jpã¨ã„ã†è¨˜äº‹ã®ä¸ã§ã€listen backlog ãŒã‚ãµã‚ŒãŸå¾Œã« accept(2) ã™ã‚‹ã¨ã€ãã®å¾Œã® read(2) ㌠EAGAIN ã‚’è¿”ã—ãŸã‚Šã€æŽ¥ç¶šãŒä¸å®‰å®šã«ãªã‚‹ã¨ã„ã†äº‹è±¡ãŒèª¬æ˜Žã•ã‚Œã¦ã„ã¾ã—ãŸã€‚æ°—ã«ãªã£ãŸã®ã§èª¿ã¹ã¦ã¿ãŸã“ã¨ã‚’ã¾ã¨ã‚ã¾ã™ã€‚ çµè«–ã‹ã‚‰è¨€ã†ã¨ã“ã‚Œã¯Linuxã®ä»•æ§˜ã§ã™ã€‚manã®tcp(7)を見るã¨ã€ TCP_DEFER_ACCEPT (since Linux 2.4) Allow a listener to be awakened only when data arrives on the socket. Takes an integer value (seconds), this can bound the maximum number of
listen()ã®backlogãŒä¸è¶³ã—ãŸéš›ã®TCP_DEFER_ACCEPTã®å‹•ä½œã«ã¤ã„㦠- blog.nomadscafe.jp
TCP_DEFER_ACCEPTã¯ã€Linuxã§ã‚µãƒãƒ¼ãƒˆã•ã‚Œã¦ã„ã‚‹TCPã®ã‚ªãƒ—ションã§ã€ã‚µãƒ¼ãƒå´ã§ä½¿ç”¨ã—ãŸå ´åˆã«ã¯accept(2)ã‹ã‚‰ã®ãƒ–ãƒãƒƒã‚¯è§£é™¤ã‚’TCP接続ãŒå®Œäº†ã—ãŸã‚¿ã‚¤ãƒŸãƒ³ã‚°ã§ã¯ãªã最åˆã®ãƒ‡ãƒ¼ã‚¿ãŒåˆ°ç€ã—ãŸã‚¿ã‚¤ãƒŸãƒ³ã‚°ã§è¡Œã£ã¦ãれるオプションã§ã™ã€‚ Webサーãƒãƒ»ã‚¢ãƒ—リケーションサーãƒã§ã¯ãƒªã‚¯ã‚¨ã‚¹ãƒˆãŒåˆ°ç€ã—ã¦ã‹ã‚‰accept(2)ã®ãƒ–ãƒãƒƒã‚¯ã‚’解除ã™ã‚‹ã®ã§ã€ãƒªã‚¯ã‚¨ã‚¹ãƒˆã®åˆ°ç€ã‚’Webサーãƒãƒ»ã‚¢ãƒ—リケーションサーãƒã§å¾…ã¤å¿…è¦ãŒãªããªã‚Šã€ç‰¹ã«preforkåž‹ã®ã‚µãƒ¼ãƒã§ã¯åŠ¹çŽ‡çš„ã«ãƒ—ãƒã‚»ã‚¹ã‚’使ãˆã‚‹ã‚ˆã†ã«ãªã‚‹ã¨ã„ã†åˆ©ç‚¹ãŒã‚ã‚Šã¾ã™ã€‚Perlã§ã¯StarletãŒã“ã®æ©Ÿèƒ½ã‚’有効ã«ã—ã¦ã„ã¾ã™ ã¨ã“ã‚ãŒã€æŸã‚µãƒ¼ãƒ“スã§TCP_DEFER_ACCEPTãŒæœ‰åŠ¹ã«ã‚‚é–¢ã‚らãšã€accept後ã®readã§ãƒ‡ãƒ¼ã‚¿ãŒèªã‚ãšã€æœ€æ‚ªã®å ´åˆã€ãƒ‡ãƒ•ã‚©ãƒ«ãƒˆã®timeoutã§ã‚ã‚‹5分間プãƒã‚»ã‚¹ãŒã‚¹ãƒˆãƒ¼ãƒ«ã™ã‚‹ã“ã¨ãŒã‚ã‚Šã¾ã—ãŸã€‚strace
ZeroMQ
Why ZeroMQ? ZeroMQ (also known as ØMQ, 0MQ, or zmq) looks like an embeddable networking library but acts like a concurrency framework. It gives you sockets that carry atomic messages across various transports like in-process, inter-process, TCP, and multicast. You can connect sockets N-to-N with patterns like fan-out, pub-sub, task distribution, and request-reply. It's fast enough to be the fabric
1
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
GitHub - mcfunley/juds: A Unix domain socket library for Java
Google Code Archive - Long-term storage for Google Code Project Hosting.
{{#tags}}- {{label}}
{{/tags}}