//文档地址

//http://doc.workerman.net/getting-started/simple-example.html

// 假设服务端ip为127.0.0.1

ws = new WebSocket("ws://127.0.0.1:2000");

ws.onopen = function() {

    alert("连接成功");

    ws.send('tom');

    alert("给服务端发送一个字符串：tom");

};

ws.onmessage = function(e) {

    alert("收到服务端的消息：" + e.data);

};

//文档地址

//http://doc.workerman.net/getting-started/simple-example.html

<?php

use Workerman\Worker;

require_once __DIR__ . '/Workerman/Autoloader.php';

// 注意：这里与上个例子不同，使用的是websocket协议

$ws_worker = new Worker("websocket://0.0.0.0:2000");

// 启动4个进程对外提供服务

$ws_worker->count = 4;

// 当收到客户端发来的数据后返回hello $data给客户端

$ws_worker->onMessage = function($connection, $data)

{

    // 向客户端发送hello $data

    $connection->send('hello ' . $data);

};

// 运行worker

Worker::runAll();

// 文档地址

// http://doc.workerman.net/install/start-and-stop.html

// 以下运行方式任选一种

// 线上环境需要以守护进程方式启动 并且要加心跳[如果不会请百度]

//以debug（调试）方式启动

php start.php start

//以daemon（守护进程）方式启动

php start.php start -d

// 文档地址

// http://doc.workerman.net/development/before-development.html

//三、区分主进程和子进程

//有必要注意下代码是运行在主进程还是子进程，一般来说在Worker::runAll();调用前运行的代码都是在主进程运行的，onXXX回调运行的代码都属于子进程。注意写在Worker::runAll();后面的代码永远不会被执行。

//例如下面的代码

require_once __DIR__ . '/Workerman/Autoloader.php';

use Workerman\Worker;

// 运行在主进程

$tcp_worker = new Worker("tcp://0.0.0.0:2347");

// 赋值过程运行在主进程

$tcp_worker->onMessage = function($connection, $data)

{

    // 这部分运行在子进程

    $connection->send('hello ' . $data);

};

Worker::runAll();

//注意： 不要在主进程中初始化数据库、memcache、redis等连接资源，因为主进程初始化的连接可能会被子进程自动继承（尤其是使用单例的时候），所有进程都持有同一个连接，服务端通过这个连接返回的数据在多个进程上都可读，会导致数据错乱。同样的，如果任何一个进程关闭连接(例如daemon模式运行时主进程会退出导致连接关闭)，都导致所有子进程的连接都被一起关闭，并发生不可预知的错误，例如mysql gone away 错误。

//推荐在onWorkerStart里面初始化连接资源。

<?php

use Workerman\Worker;

require_once __DIR__ . '/Workerman/Autoloader.php';

//

$ws_worker = new Worker('websocket://127.0.0.1:2000');

// // 新增加一个属性，用来保存uid到connection的映射(uid是用户id或者客户端唯一标识)

$worker->uidConnections = array();

// 手册说只能一个

$ws_worker->count = 1;

// 当收到客户端发来的数据后返回hello $data给客户端

$ws_worker->onMessage = function ($connection, $data) {

    global $ws_worker;

    // 客户端的第一次消息当作获取uid

    // 判断当前客户端是否已经验证,即是否设置了uid

    // 这里只是简单的把 $connection->id 当作他的uid 因为 connection->id 是唯一的

    if (!isset($connection->uid)) {

        $connection->uid = $connection->id;

        $ws_worker->uidConnections[$connection->uid] = $connection;

        return $connection->send($connection->uid);

    }

    //获取uid

    list($uid, $message) = explode(':', $data);

    //判断id是否存在 然后发送消息

    if (isset($ws_worker->uidConnections[$uid])) {

        $connection = $ws_worker->uidConnections[$uid];

        $connection->send("自定义消息内容");

    }

};

// 运行worker

Worker::runAll();

ws = new WebSocket("ws://127.0.0.1:2000");

var uid = "";

ws.onmessage = function (e) {

            //设置uid

            if(uid == ""){

                uid = e.data;

                return ;

            }

            //实现逻辑代码区域

            //....

}