Package Data | |
---|---|
Maintainer Username: | Cherry Pie |
Maintainer Contact: | 12fcv4@gmail.com (Yaro) |
Package Create Date: | 2015-02-15 |
Package Last Update: | 2015-12-04 |
Home Page: | |
Language: | PHP |
License: | MIT |
Last Refreshed: | 2024-11-14 15:09:43 |
Package Statistics | |
---|---|
Total Downloads: | 353 |
Monthly Downloads: | 1 |
Daily Downloads: | 0 |
Total Stars: | 11 |
Total Watchers: | 2 |
Total Forks: | 9 |
Total Open Issues: | 0 |
Fork of morozovsk/websocket for Laravel 4/5 integration.
composer require yaro/socket
Add to config/app.php:
'providers' => array(
//...
Yaro\Socket\ServiceProvider::class,
//...
),
'aliases' => array(
//...
'Socket' => Yaro\Socket\Facade::class,
//...
),
Sample command:
use Illuminate\Console\Command;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Input\InputArgument;
class ChatCommand extends Command
{
protected $name = 'socket:chat';
protected $description = "chat command";
public function fire()
{
Socket::init($this->argument('action'), array(
'class' => 'ChatWebsocketDaemonHandler',
'pid' => '/tmp/websocket_chat.pid',
'websocket' => 'tcp://127.0.0.1:8000',
//'localsocket' => 'tcp://127.0.0.1:8010',
//'master' => 'tcp://127.0.0.1:8020',
//'eventDriver' => 'event'
));
} // end fire
protected function getArguments()
{
return array(
array('action', InputArgument::REQUIRED, 'start|stop|restart'),
);
} // end getArguments
protected function getOptions()
{
return array();
} // end getOptions
}
Sample handler class:
class ChatWebsocketDaemonHandler extends WebsocketDaemon
{
protected function onOpen($connectionId, $info)
{
}
protected function onClose($connectionId)
{
}
protected function onMessage($connectionId, $data, $type)
{
if (!strlen($data)) {
return;
}
$message = 'user #'. $connectionId .' ('. $this->pid .'): '. strip_tags($data);
foreach ($this->clients as $idClient => $client) {
$this->sendToClient($idClient, $message);
}
}
}
And run your command (command from example):
php artisan socket:chat
And your js on front will be like this:
var ws = new WebSocket("ws://127.0.0.1:8000/");
ws.onopen = function() {
console.log('socket: open');
};
ws.onclose = function() {
console.log('socket: close');
};
ws.onmessage = function(evt) {
console.log(evt.data);
};