web-msg-sender的https支持改造

用的是nginx代理转发443到2120端口实现，官方说workman原生支持，没有实现（现象是访问 htttps://域名:2120/ 超时，不知道是服务器问题还是什么）

后转为用nginx代理转发实现

1、假设用https://socket.test.com 作为socket连接的地址. https://www.test.com还是网站本身，实现共存，不影响主站访问

1、nginx的网站.conf，注意红色部分。2121那个转发不是必须的，因为是服务端curl请求，可以直接请求ip地址带端口

server

    {

    listen 443;

    server_name *.test.com test.com;

    set $flag 0;

if ($host != 'www.test.com') {

        set $flag "${flag}1";

}

if ($host = 'socket.test.com'){

        set $flag "${flag}1";

}

if ($flag = "01"){

        rewrite ^/(.*)$ http://www.test.com/$1 permanent;

}

    #if ($host != 'www.test.com' ) {

   # }

    ssl on;

    ssl_certificate   cert/cert-1542176077391__.test.com.crt;

    ssl_certificate_key  cert/cert-1542176077391__.test.com.key;

    ssl_session_timeout 5m;

    ssl_ciphers ECDHE-RSA-AES128-GCM-SHA256:ECDHE:ECDH:AES:HIGH:!NULL:!aNULL:!MD5:!ADH:!RC4;

    ssl_protocols TLSv1 TLSv1.1 TLSv1.2;

    ssl_prefer_server_ciphers on;

        index index.html index.htm index.php default.html default.htm default.php;

        root  /home/wwwroot/test;

        error_page   404   /404.html;

location /push.api

  {

    proxy_pass http://127.0.0.1:2121;

    proxy_http_version 1.1;

    proxy_set_header Upgrade $http_upgrade;

    proxy_set_header Connection "Upgrade";

    proxy_set_header X-Real-IP $remote_addr;

  }

location /socket.io

  {

    proxy_pass http://127.0.0.1:2120;

    proxy_http_version 1.1;

    proxy_set_header Upgrade $http_upgrade;

    proxy_set_header Connection "Upgrade";

    proxy_set_header X-Real-IP $remote_addr;

  }

        location /{

        if (!-e $request_filename) {

            rewrite ^/(.+\.(html|xml|json|htm|php|jsp|asp|shtml))$ /index.php?$1 last;

        }

        # Deny access to PHP files in specific directory

        #location ~ /(wp-content|uploads|wp-includes|images)/.*\.php$ { deny all; }

            include enable-php5.2.conf;

        }

        location ~ .*\.(gif|jpg|jpeg|png|bmp|swf)$

        {

            expires      30d;

        }

        location ~ .*\.(js|css)?$

        {

            expires      12h;

        }

        location ~ /.well-known {

            allow all;

        }

        location ~ /\.

        {

            deny all;

        }

        #access_log  /home/wwwlogs/test.com.log;

    }

2、服务端socket.io.php，无需更改。还是用端口2120,不用开启ssl

<?php

use Workerman\Worker;

use Workerman\WebServer;

use Workerman\Lib\Timer;

use PHPSocketIO\SocketIO;

include __DIR__ . '/vendor/autoload.php';

// 全局数组保存uid在线数据

$uidConnectionMap = array();

// 记录最后一次广播的在线用户数

$last_online_count = 0;

// 记录最后一次广播的在线页面数

$last_online_page_count = 0;

// PHPSocketIO服务

$sender_io = new SocketIO(2120);

// 客户端发起连接事件时，设置连接socket的各种事件回调

$sender_io->on('connection', function($socket){

    file_put_contents('/home/wwwroot/test/home/socketioserver.txt',date('Y-m-d H:i:s')."\r\n connection:uid:".$uid."\r\n=======\r\n",FILE_APPEND);

    /**/

   // error_reporting(E_ALL ^ E_NOTICE);

    //$root_dir = realpath(dirname(__FILE__).'/../');

    //require_once($root_dir."/config/config.php");

/*

    require_once(APP_DIR.'/base/kernel.php');

    @require_once(APP_DIR.'/base/defined.php');

    if(!kernel::register_autoload()){

        require_once(APP_DIR.'/base/autoload.php');

    }*/

    /**/

    // 当客户端发来登录事件时触发

    $socket->on('login', function ($uid)use($socket){

        file_put_contents('/home/wwwroot/test/home/socketioserver.txt',date('Y-m-d H:i:s')."\r\n login:uid:".$uid."\r\n=======\r\n",FILE_APPEND);

        global $uidConnectionMap, $last_online_count, $last_online_page_count;

        // 已经登录过了

        if(isset($socket->uid)){

            return;

        }

        // 更新对应uid的在线数据

        $uid = (string)$uid;

        if(!isset($uidConnectionMap[$uid]))

        {

            $uidConnectionMap[$uid] = 0;

        }

        // 这个uid有++$uidConnectionMap[$uid]个socket连接

        ++$uidConnectionMap[$uid];

  /*       $dbs= kernel::database();

        $dbs->exec('update sdb_b2c_online_users set online="'.serialize($uidConnectionMap).'"');*/

        //file_put_contents(HOME_DIR.'/chat/OnlineUsersCache.txt',serialize($uidConnectionMap));

        //app::get('b2c')->setConf('chat.online_users',$uidConnectionMap);

        // 将这个连接加入到uid分组，方便针对uid推送数据

        $socket->join($uid);

        $socket->uid = $uid;

        // 更新这个socket对应页面的在线数据

        $socket->emit('update_online_count',count($uidConnectionMap));

    });

    // 当客户端断开连接是触发（一般是关闭网页或者跳转刷新导致）

    $socket->on('disconnect', function () use($socket) {

        file_put_contents('/home/wwwroot/test/home/socketioserver.txt',date('Y-m-d H:i:s')."\r\n disconnect:uid:".$socket->uid."\r\n=======\r\n",FILE_APPEND);

        if(!isset($socket->uid))

        {

             return;

        }

        global $uidConnectionMap, $sender_io;

        // 将uid的在线socket数减一

        if(--$uidConnectionMap[$socket->uid] <= 0)

        {

            unset($uidConnectionMap[$socket->uid]);

        }

       // file_put_contents(HOME_DIR.'/chat/OnlineUsersCache.txt',serialize($uidConnectionMap));

    });

});

// 当$sender_io启动后监听一个http端口，通过这个端口可以给任意uid或者所有uid推送数据

$sender_io->on('workerStart', function(){

    // 监听一个http端口

    $inner_http_worker = new Worker('http://0.0.0.0:2121');

    // 当http客户端发来数据时触发

    $inner_http_worker->onMessage = function($http_connection, $data){

        $_POST = $_POST ? $_POST : $_GET;

        if($_POST['appkey']!='fads'){

           // return $http_connection->send('fail');

        }

        // 推送数据的url格式 type=publish&to=uid&content=xxxx

        switch(@$_POST['type']){

            //聊天

              case 'publish':

                global $sender_io;

                $to = @$_POST['to'];

                $_POST['content'] = (@$_POST['content']);

                // 有指定uid则向uid所在socket组发送数据

                if($to){

                    $sender_io->to($to)->emit('new_msg', $_POST['content']);

                // 否则向所有uid推送数据

                }else{

                    $sender_io->emit('new_msg', @$_POST['content']);

                }

                // http接口返回ok

                return $http_connection->send('ok');

                break;

            //新的拍卖出价时

              case 'new_auction_price':

                global $sender_io;

                $to = @$_POST['to'];

                $_POST['content'] = (@$_POST['content']);

                // 有指定uid则向uid所在socket组发送数据

                if($to){

                    $sender_io->to($to)->emit('new_auction', $_POST['content']);

                    // 否则向所有uid推送数据

                }else{

                    $sender_io->emit('new_auction_price', @$_POST['content']);

                }

                return $http_connection->send('ok');

                break;

                //创建拍卖

                case 'create_auction':

                global $sender_io;

                $to = @$_POST['to'];

                // 有指定uid则向uid所在socket组发送数据

                if($to){

                    $sender_io->to($to)->emit('create_auction', $_POST['content']);

                    // 否则向所有uid推送数据

                }else{

                    $sender_io->emit('create_auction', @$_POST['content']);

                }

                return $http_connection->send('ok');

                break;

                //延迟

                case 'delay_auction':

                global $sender_io;

                $to = @$_POST['to'];

                // 有指定uid则向uid所在socket组发送数据

                if($to){

                    $sender_io->to($to)->emit('delay_auction', $_POST['content']);

                    // 否则向所有uid推送数据

                }else{

                    $sender_io->emit('delay_auction', @$_POST['content']);

                }

                return $http_connection->send('ok');

                break;

                 //流拍

                case 'cancel_auction':

                global $sender_io;

                $to = @$_POST['to'];

                // 有指定uid则向uid所在socket组发送数据

                if($to){

                    $sender_io->to($to)->emit('cancel_auction', $_POST['content']);

                    // 否则向所有uid推送数据

                }else{

                    $sender_io->emit('cancel_auction', @$_POST['content']);

                }

                return $http_connection->send('ok');

                break;

              //开始今日拍卖时+切换到下一个拍卖时+结束当日拍卖到下一个拍卖时

              case 'change_domain_item':

                global $sender_io;

                $to = @$_POST['to'];

                // 有指定uid则向uid所在socket组发送数据

                if($to){

                    $sender_io->to($to)->emit('change_domain_item', $_POST['content']);

                    // 否则向所有uid推送数据

                }else{

                    $sender_io->emit('change_domain_item', @$_POST['content']);

                }

                return $http_connection->send('ok');

        }

        return $http_connection->send('fail');

    };

    // 执行监听

    $inner_http_worker->listen();

    // 一个定时器，定时向所有uid推送当前uid在线数及在线页面数

    Timer::add(1, function(){

        global $uidConnectionMap, $sender_io, $last_online_count, $last_online_page_count;

        $online_count_now = count($uidConnectionMap);

        $online_page_count_now = array_sum($uidConnectionMap);

        // 只有在客户端在线数变化了才广播，减少不必要的客户端通讯

        if($last_online_count != $online_count_now || $last_online_page_count != $online_page_count_now)

        {

            $sender_io->emit('update_online_count', $online_count_now);

            $last_online_count = $online_count_now;

            $last_online_page_count = $online_page_count_now;

        }

    });

});

if(!defined('GLOBAL_START'))

{

    Worker::runAll();

}

3、客户端js.最大的坑就是这里。原先以为io('地址')，是要填完整的,比如下面

<script src='https://socket.test.com/web-msg-sender-master/socket.io-client/socket.io.js?v=123123'></script>

<script>
$(document).ready(function () {
            // 创建WebSocket 对象
    var socket = io("https://socket.test.com/socket.io",{debug:true});
    /*
    * 2019-08-24 11:27:35
     connection:uid:
     =======
     2019-08-24 11:28:04
     disconnect:uid:
    *
    * */

    //var socket = io("http://118.190.21.61:2120",{debug:true});
    /*
    * 2019-08-24 11:26:08
     connection:uid:
     =======
     2019-08-24 11:26:08
     login:uid:1566617168000
     =======
     2019-08-24 11:26:35
     disconnect:uid:1566617168000
     =======
    * */

    //连接成功时，触发事件
    // 连接后登录
    console.log('socket',socket);
    socket.on('connect', function(){
        socket.emit('login', uid);
    });
    // 后端推送来消息时
    socket.on('new_msg', function(msg){
        $('#content').html('收到消息：'+msg);
        $('.notification.sticky').notify();
    });
    // 后端推送来在线数据时
    socket.on('update_online_count', function(online_stat){
        $('#online_box').html(online_stat);
    });

 })
  </script>

后来发现怎么也连不上socket服务，on事件监听完全失效。

后来看了 lib/manager.js里源码才知道，系统会自动补全socket.io，所以初始化时io里变量只需填写域名即可，正确如下。注意红色加粗部分

<script src='https://socket.test.com/web-msg-sender-master/socket.io-client/socket.io.js?v=123123'></script>

<script>

$(document).ready(function () {

            // 创建WebSocket 对象

    var socket = io("https://socket.test.com",{debug:true});

    /*

    * 2019-08-24 11:27:35

     connection:uid:

     =======

     2019-08-24 11:28:04

     disconnect:uid:

    *

    * */

    //var socket = io("http://118.190.21.61:2120",{debug:true});

    /*

    * 2019-08-24 11:26:08

     connection:uid:

     =======

     2019-08-24 11:26:08

     login:uid:1566617168000

     =======

     2019-08-24 11:26:35

     disconnect:uid:1566617168000

     =======

    * */

    //连接成功时，触发事件

    // 连接后登录

    console.log('socket',socket);

    socket.on('connect', function(){

        socket.emit('login', uid);

    });

    // 后端推送来消息时

    socket.on('new_msg', function(msg){

        $('#content').html('收到消息：'+msg);

        $('.notification.sticky').notify();

    });

    // 后端推送来在线数据时

    socket.on('update_online_count', function(online_stat){

        $('#online_box').html(online_stat);

    });

 })

  </script>

巴特西

web-msg-sender的https支持改造

最新文章

热门文章