phpsocket.io

Notice

Install

Examples

Simple chat

use Workerman\Worker;
use PHPSocketIO\SocketIO;
// listen port 2021 for socket.io client
$io = new SocketIO(2021);
$io->on('connection', function($socket)use($io){
 $socket->on('chat message', function($msg)use($io){
 $io->emit('chat message', $msg);
 });
});
Worker::runAll();

Another chat demo

use Workerman\Worker;
use PHPSocketIO\SocketIO;
// listen port 2020 for socket.io client
$io = new SocketIO(2020);
$io->on('connection', function($socket){
 $socket->addedUser = false;
 // when the client emits 'new message', this listens and executes
 $socket->on('new message', function ($data)use($socket){
 // we tell the client to execute 'new message'
 $socket->broadcast->emit('new message', array(
 'username'=> $socket->username,
 'message'=> $data
 ));
 });
 // when the client emits 'add user', this listens and executes
 $socket->on('add user', function ($username) use($socket){
 global $usernames, $numUsers;
 // we store the username in the socket session for this client
 $socket->username = $username;
 // add the client's username to the global list
 $usernames[$username] = $username;
 ++$numUsers;
 $socket->addedUser = true;
 $socket->emit('login', array( 
 'numUsers' => $numUsers
 ));
 // echo globally (all clients) that a person has connected
 $socket->broadcast->emit('user joined', array(
 'username' => $socket->username,
 'numUsers' => $numUsers
 ));
 });
 // when the client emits 'typing', we broadcast it to others
 $socket->on('typing', function () use($socket) {
 $socket->broadcast->emit('typing', array(
 'username' => $socket->username
 ));
 });
 // when the client emits 'stop typing', we broadcast it to others
 $socket->on('stop typing', function () use($socket) {
 $socket->broadcast->emit('stop typing', array(
 'username' => $socket->username
 ));
 });
 // when the user disconnects.. perform this
 $socket->on('disconnect', function () use($socket) {
 global $usernames, $numUsers;
 // remove the username from global usernames list
 if($socket->addedUser) {
 unset($usernames[$socket->username]);
 --$numUsers;
 // echo globally that this client has left
 $socket->broadcast->emit('user left', array(
 'username' => $socket->username,
 'numUsers' => $numUsers
 ));
 }
 });
});
Worker::runAll();

Enable SSL for https

<?php
require_once __DIR__ . '/vendor/autoload.php';
use Workerman\Worker;
use PHPSocketIO\SocketIO;
// ssl context
$context = array(
 'ssl' => array(
 'local_cert' => '/your/path/of/server.pem',
 'local_pk' => '/your/path/of/server.key',
 'verify_peer' => false,
 )
);
$io = new SocketIO(2021, $context);
$io->on('connection', function($connection)use($io){
 echo "new connection coming\n";
});
Worker::runAll();

手册

Livedemo

Run chat example

Start

Stop

Status

License