Use all power of socket.io in your Yii 2 project.
cd ~
curl -sL https://deb.nodesource.com/setup_6.x -o nodesource_setup.sh
sudo bash nodesource_setup.sh
cd vendor/yiicod/yii2-soketio/server
npm install
'controllerMap' => [
'socketio' => [
'class' => \yiicod\socketio\commands\SocketIoCommand::class,
'server' => 'localhost:1367'
],
]
php yii socketio/start
php yii socketio/stop
OR use pm2(http://pm2.keymetrics.io/). This variant more preferable.
'controllerMap' => [
'socketio' => [
'class' => \yiicod\socketio\commands\WorkerCommand::class,
'server' => 'localhost:1367'
],
]
{
"apps": [
{
"name": "socket-io-node-js-server",
"script": "yii",
"args": [
"socketio/node-js-server"
],
"exec_interpreter": "php",
"exec_mode": "fork_mode",
"max_memory_restart": "1G",
"watch": false,
"merge_logs": true,
"out_file": "runtime/logs/node_js_server_out.log",
"error_file": "runtime/logs/node_js_server_err.log"
},
{
"name": "socket-io-php-server",
"script": "yii",
"args": [
"socketio/php-server"
],
"exec_interpreter": "php",
"exec_mode": "fork_mode",
"max_memory_restart": "1G",
"watch": false,
"merge_logs": true,
"out_file": "runtime/logs/php_server_out.log",
"error_file": "runtime/logs/php_server_err.log"
},
]
}
pm2 start daemons-app.json
php yii socketio/node-js-server
php yii socketio/php-server
'components' =>[
'broadcastEvents' => [
'class' => \yiicod\socketio\EventManager::class,
'nsp' => 'some_unique_key',
// Namespaces with events folders
'namespaces' => [
'app\socketio',
]
],
'broadcastDriver' => [
'class' => \yiicod\socketio\drivers\RedisDriver::class,
'hostname' => 'localhost',
'port' => 6379,
],
]
use yiicod\socketio\events\EventInterface;
use yiicod\socketio\events\EventPubInterface;
class CountEvent implements EventInterface, EventPubInterface
{
/**
* Changel name. For client side this is nsp.
*/
public static function broadcastOn(): array
{
return ['notifications'];
}
/**
* Event name
*/
public static function name(): string
{
return 'update_notification_count';
}
/**
* Emit client event
* @param array $data
* @return array
*/
public function fire(array $data): array
{
return $data;
}
}
var socket = io('localhost:1367/notifications');
socket.on('update_notification_count', function(data){
console.log(data)
});
//Run broadcast to client
\yiicod\socketio\Broadcast::emit(CountEvent::name(), ['count' => 10])
use yiicod\socketio\events\EventInterface;
use yiicod\socketio\events\EventSubInterface;
class MarkAsReadEvent implements EventInterface, EventSubInterface
{
/**
* Changel name. For client side this is nsp.
*/
public static function broadcastOn(): array
{
return ['notifications'];
}
/**
* Event name
*/
public static function name(): string
{
return 'mark_as_read_notification';
}
/**
* Emit client event
* @param array $data
* @return array
*/
public function handle(array $data)
{
// Mark notification as read
// And call client update
// Broadcast::emit('update_notification_count', ['some_key' => 'some_value']);
// Push some log
file_put_contents(\Yii::getAlias('@app/../file.txt'), serialize($data));
}
}
var socket = io('localhost:1367/notifications');
socket.emit('mark_as_read_notification', {id: 10});
You can have publisher and receiver in one event. If you need check data from client to server you should use:
- EventPolicyInterface
use yiicod\socketio\events\EventSubInterface;
use yiicod\socketio\events\EventInterface;
use yiicod\socketio\events\EventPolicyInterface;
class MarkAsReadEvent implements EventInterface, EventSubInterface, EventPolicyInterface
{
/**
* Changel name. For client side this is nsp.
*/
public static function broadcastOn(): array
{
return ['notifications'];
}
/**
* Event name
*/
public static function name(): string
{
return 'mark_as_read_notification';
}
public function can($data): bool
{
// Check data from client
return true;
}
/**
* Emit client event
* @param array $data
* @return array
*/
public function handle(array $data)
{
// Mark notification as read
// And call client update
Broadcast::emit('update_notification_count', ['some_key' => 'some_value']);
}
}
Soket.io has room functionl. If you need it, you should implement:
- EventRoomInterface
use yiicod\socketio\events\EventPubInterface;
use yiicod\socketio\events\EventInterface;
use yiicod\socketio\events\EventRoomInterface;
class CountEvent implements EventInterface, EventPubInterface, EventRoomInterface
{
/**
* User id
* @var int
*/
protected $userId;
/**
* Changel name. For client side this is nsp.
*/
public static function broadcastOn(): array
{
return ['notifications'];
}
/**
* Event name
*/
public static function name(): string
{
return 'update_notification_count';
}
/**
* Socket.io room
* @return string
*/
public function room(): string
{
return 'user_id_' . $this->>userId;
}
/**
* Emit client event
* @param array $data
* @return array
*/
public function fire(array $data): array
{
$this->userId = $data['userId'];
return [
'count' => 10,
];
}
}
var socket = io('localhost:1367/notifications');
socket.emit('join', {room: 'user_id_'<?= 10 ?>});
// Now you will receive data from 'room-1'
socket.on('update_notification_count', function(data){
console.log(data)
});
// You can leave room
socket.emit('leave');
//Run broadcast to user id = 10
\yiicod\socketio\Broadcast::emit(CountEvent::name(), ['count' => 10, 'userId' => 10])