danci/www.hanlinyuanonline.com/Application/Home/Controller/IndexController.class.php

<?php
namespace Home\Controller;
use Think\Controller;
class IndexController extends Controller {
    public function index(){
        $this->redirect('/admin/login');exit;
        $this->uid = I('uid','159753');
        session('uid', $this->uid);
        $this->display();
    }
    
    public function bind() {
        $uid = session('uid');
        $client_id = I('client_id'); 
        $group_id = 456;
        $gateway = new \Org\Net\Gateway();
        $gateway->setSession($client_id,array('room_id'=>$group_id));
        $gateway->bindUid($client_id, $uid); 
        $gateway->joinGroup($client_id, $group_id);
        $message = '绑定成功' . $uid . '-' . $client_id; 
        $gateway->sendToUid($uid, $message); 
    }
    
    public function message() { 
        $to_uid = I('uid'); 
        $message = I('msg'); 
        $gateway = new \Org\Net\Gateway(); 
        $data['msg'] = $message; 
        $data['from_uid'] = session('uid'); 
        $data['to_uid'] = $to_uid; 
        $gateway->sendToUid($to_uid, json_encode($data)); //发给对方 
        $gateway->sendToUid($data['from_uid'], json_encode($data)); //发给自己 
        echo json_encode($data); 
    }
}


/* class Push{
     
    public function helloAction () {
        $uid = $_GET['uid'];
        session('uid', $uid);

        $view = new View;
        return $view->fetch();
    }

    public function BindClientIdAction () {

        $client_id = $_POST['client_id'];
        // 设置GatewayWorker服务的Register服务ip和端口，请根据实际情况改成实际值
        Gateway::$registerAddress = '127.0.0.1:1238';

        $bindUid = session('uid');
        // 假设用户已经登录，用户uid和群组id在session中
        // client_id与uid绑定
        Gateway::bindUid($client_id, $bindUid);
        // 加入某个群组（可调用多次加入多个群组）
        // Gateway::joinGroup($client_id, $group_id);
    }

    public function AjaxSendMessageAction () {
        $message = $_POST['message'];
        // 设置GatewayWorker服务的Register服务ip和端口，请根据实际情况改成实际值
        Gateway::$registerAddress = '127.0.0.1:1238';

        GateWay::sendToAll($message);
    }
} */