php - Route requests to Laravel Controller to running WebSocket server -


the situation:

there long-running task needs launched asynchronously. details of task aren't important (the basics multiple vms going provisioned , complex network setup), , being handled python script running on different server. decided go websockets communication , forth between web server , client, , have bi-directional communication there working. web server sending requests other server, , receive http post notifications python script when each machine , running, , final http post when entire network up.

all of works. framework we're using on web server laravel 4, , web socket server built using ratchet, , implemented in artisan command. issue i'm not sure how relay http posts laravel controller python script websocket server in turn can relay information client.

below implementation of ratchet's messagecomponentinterface::onmessage method, using observer pattern notify subscribed listeners of message event.

// class: socketmessenger public function onmessage(connectioninterface $from, $msg) {     $respondto = null;     foreach($this->_clients $client) {         if($client->resourceid == $from->resourceid) {             $respondto = $client;             break;         }     }      $msg = json_decode($msg, true);      if(!$respondto || !$msg || !isset($msg['type'])) {         echo 'malformed socket message received, rejecting.';         return;     }      $type = $msg['type'];      // notify subscribed listeners message type of      // incoming message. response received relayed      // client.     if(isset($this->_listeners[$type])) {         foreach( $this->_listeners[$type] $listener ) {             $response = $listener->notify( $respondto, $msg );             if($response) {                 $respondto->send( $response );             }         }     } }

the websocket server constructed within service provider this:

// class: socketserviceprovider $app->bind( 'ratchet\messagecomponentinterface', function( $app, $params ) {     $port = $params && isset($params[0]) ?         $params[0] : self::default_port     ;      $messenger = new socketmessenger;      // setup ratchet server.     $server = ioserver::factory(         new httpserver(             new wsserver(                  $messenger             )         ),         $port     );      // subscribe socket listeners socket messenger     $messenger->subscribe( new topologymessagelistener, topologymessagelistener::type );      return $server; } );

is there way take requests laravel controller , notify running websocket server whenever given controller's method hit?

the answer here appears need create websocket client in php send messages websocket server, same client written in javascript would. interested viewers struggling same issue, able find few websocket clients written in php:

  1. https://github.com/gabrielbull/php-websocket-client
  2. https://github.com/devristo/phpws
  3. https://github.com/symbiose/php-websocket-client (<-- 1 wound going with)

i'll leaving question open awhile in case comes different idea / better client library use.


Comments

Post a Comment

Popular posts from this blog

Android layout hidden on keyboard show -

i have strange problem layout. when tap on edittext , keyboard shown edittext stay on bottom , when tap on to hide keyboard , keyboard hides , edittext go should when want input text. when tap again, keyboard shown , edittext goes down behind keyboard... <relativelayout android:layout_width="match_parent" android:layout_height="match_parent" > <scrollview android:layout_width="match_parent" android:layout_height="fill_parent" android:above="@+id/rl_commands"> <textview android:layout_width="match_parent" android:layout_height="wrap_content"/> </scrollview> <relativelayout android:layout_width="match_parent android:layout_height="24dp" android:id="@+id/rl_commands" android:alignparentbottom="true">
Read more

google app engine - 403 Forbidden POST - Flask WTForms -

i have flask application running on google app engine. trying submit form built using wtform , keep getting following error. 403 forbidden: don't have permission access requested resource. either read-protected or not readable server. location.html (part of code) <form method=post action="/home/location"> .... <button type="submit" class="btn btn-primary" value="submit"> directions </button> </form> main.py @app.route('/home/location', methods=['post', 'get']) def location(): form = cfcdirections.direction(request.form) print(request.method) if request.method == 'post' , form.validate(): print("after if") directions = cfcdirections() street_no = directions.no street = directions.street suburb = directions.suburb postcode = directions.postcode
Read more

c - Why would PK11_GenerateRandom() return an error -8023? -

i looking through internet trying find source of pk11_generaterandom() function see why function fail. have program uses function when moved new flavor of linux, fails after forking ( fork() ) since not believe there problem nss, suspect doing incorrectly disregarded in older versions of linux new 1 there issue. the openssl package same on 'good' , 'bad' server: openssl 0.9.8e-fips-rhel5 01 jul nss rpm differs though. 'good' has nss-3.12.2.0-2.el5 and bas has version nss-3.15.3-4.el5_10 the 'good' server uses quite obsolete linux: linux 2.6.18-128.el5 #1 smp wed jan 21 08:45:05 est 2009 x86_64 x86_64 x86_64 gnu/linux enterprise linux enterprise linux server release 5.3 (carthage) red hat enterprise linux server release 5.3 (tikanga) the 'bad' server newer: linux bad 2.6.18-371.4.1.el5 #1 smp wed jan 29 11:05:49 pst 2014 x86_64 x86_64 x86_64 gnu/linux oracle linux server release 5.10 red hat enterprise linux server release
Read more