Download the PHP package domraider/rxnet without Composer
On this page you can find all versions of the php package domraider/rxnet. It is possible to download/install these versions without Composer. Possible dependencies are resolved automatically.
Informations about the package rxnet
RxNet
RxPhp is a great work that brings us Reactive programming : asynchronous programming for human being.
You can play with reactiveX on RxMarble.com, find all the available operators on the official Reactivex.io website or read an interesting introduction.
RxNet is an effort to bring it battery included.
- Dns
- Http
- Httpd
- RabbitMq
- Redis
- ZeroMq
- InfluxDB
- Statsd
- Others outside
- voryx/pg-async postgres client
- RxPHP/RxStream stream
- RxPHP/RxWebsocket websocket client / server
- RxPHP/RxChildProcess forking
Thanks to react/react, its marvelous reactor pattern and all work done with it, many are just simple wrappers.
Installation
With composer :
Or just clone the lib, run and try the examples scripts.
Why one repository for all ? Because when you start using it you want every libraries to be RxFriendly :)
Dns
Asynchronous DNS resolver. Thanks to daverandom/libdns parser it was a breeze to code.
No extra extensions are needed
Http
HTTP client with all ReactiveX sweet
No extra extensions are needed
TODO
[ ] Psr7 request/response
[ ] multipart
[ ] gzip/deflate
HttpD
Standalone HTTP server based on react/http implements nikic/fast-route as default router
No extra extensions are needed
Performances on a macbook pro are around 500 msg/s for one php process.
Remember that it does not need any fpm to run. And that default fpm configuration is with 10 childs.
Todo
[ ] Psr7 Request / Response
[ ] gzip / deflate
[ ] http2
[ ] multipart ?
[ ] ssl ? :D
RabbitMq
Wrapper from jakubkulhan/bunny that works just fine
No extra extensions are needed
Consume
Produce
TODO
[ ] add all possible options has constant
Redis
Wrapper from clue/redis (great work !)
No extra extensions are needed
ZeroMq
Message exchange through tcp (or ipc or inproc).
Needs Pecl ZMQ extension to work
Router/dealer is a both direction communication. Dealer will wait for the router, router will not, so dealer has to start first
Different protocols
You can do push/pull
, req/rep
, read ØMQ - The Guide to see what network models fits you.
5k to 10k msg/s in router dealer. 30k msg/s in push pull.
TODO
[ ] pub/sub
InfluxDB
InfluxDB client based on influxdata/influxdb-php It only supports UDP protocol for the moment (write only). Our primary goal was to have a non blocking client to send metrics.
Statsd
Statsd client based on this gist and php-datadogstatsd for tagging support.
Mysql
The mysql client uses mysqli.
Sweet
AwaitOnce
Classic procedural is always possible but take care of side effects
Await
Using rx/await you can transform you observable to a generator
On demand
OnBackPressureBuffer
OnBackPressureBufferFile
if consuming is slower than producing, next element will be written to file in givent folder.
On start, read buffer's path to search for existing and un-consumed events
All versions of rxnet with dependencies
reactivex/rxphp Version ^1.1
react/react Version 0.4.2
ramsey/uuid Version ^3.5.1
nikic/fast-route Version ^1.2
guzzlehttp/guzzle Version ^6.0
guzzlehttp/psr7 Version ~1.4.0
domraider/libdns Version ^1.1
domraider/bunny Version @dev
clue/redis-react Version ^1.0
voryx/event-loop Version 0.2.*
phpoption/phpoption Version ^1.5
anahkiasen/underscore-php Version ^2.0