composer require streetlamp/think-workerman-jsonrpcCopy

#!/usr/bin/env php
<?php
require_once __DIR__.'/vendor/autoload.php';
new \streetlamp\rpcServer\RpcServer();Copy

<?php
 return [
            //服务端配置
            'rpc_server' => [
                //worker进程数
                'processes'         => 1,
                //通信协议
                'protocol'          => '\streetlamp\rpcServer\JsonNL',
                //地址
                'host'              => '0.0.0.0',
                //端口
                'port'              => 2015,
                'socket'            => '',
                //统计数据的协议地址
                'statistic_address' => 'udp://127.0.0.1:9200',
                //服务进程名
                'worker_name'       => 'vitec',
                //日志路径
                'log_file'          => RUNTIME_PATH . 'workerman/log.log',
                //服务
                'service'           => [
                    'User' => \app\test\logic\User::class
                ]
            ]
        ];Copy

#!/usr/bin/env php
<?php
require_once __DIR__.'/vendor/autoload.php';
new \streetlamp\rpcServer\RpcServer("/var/www/html/application/config.php");Copy

#!/usr/bin/env php
<?php
require_once __DIR__.'/vendor/autoload.php';
 $config = [
            'rpc_server' => [
                'processes'         => 1,
                'protocol'          => '\streetlamp\rpcServer\JsonNL',
                'host'              => '0.0.0.0',
                'port'              => 2015,
                'socket'            => '',
                'statistic_address' => 'udp://127.0.0.1:9200',
                'worker_name'       => 'vitec',
                'log_file'          => RUNTIME_PATH . 'workerman/log.log',
                'service'           => ['User' => \app\test\logic\User::class]
            ]
        ];
new \streetlamp\rpcServer\RpcServer($config);Copy

#!/usr/bin/env php
<?php
define('APP_PATH', __DIR__ . '/application/');
define('BIND_MODULE', 'rpc/RpcServer');
// 加载框架引导文件
require __DIR__ . '/thinkphp/start.php';Copy

<?php

namespace app\rpc\controller;

class RpcServer extends \streetlamp\rpcServer\RpcServer
{
}Copy

<?php
// User对应服务端配置中service里面的映射类，$config为配置文件的绝对路径或数组

$config = 'client_config.php';

$user_client = streetlamp\rpcClient\RpcClient::instance('User',$config);

// getInfoByUid对应User类中的getInfoByUid方法

$ret_sync = $user_client->getInfoByUid($uid);Copy

<?php
// User对应服务端配置中service里面的映射类，$config为配置文件的绝对路径或数组

$config = 'client_config.php';

$user_client = streetlamp\rpcClient\RpcClient::instance('User',$config);

// getInfoByUid对应User类中的getInfoByUid方法
//异步调用User::getInfoByUid方法
user_client = $user_client->asend_getInfoByUid($uid);

这里是其它的业务代码
....................
....................

// 需要数据的时候异步接收数据
$ret_async2 = $user_client->arecv_getInfoByUid($uid);Copy

<?php

//客户端配置
return [
 //驱动方式
 'type'               => 'workerman', 
 //服务端连接池
 'rpc_server_address' => [ 'tcp://127.0.0.1:2015' ], 
 //重连次数
 'reconnect_count'    => 1
];Copy

<?php
$user_client = streetlamp\rpcClient\RpcClient::instance('User',"/var/www/html/application/config.php");
Copy

<?php
$user_client = streetlamp\rpcClient\RpcClient::instance(
            'User',
            [
                'type'               => 'workerman',
                'rpc_server_address' => ['tcp://127.0.0.1:2015'],
                'reconnect_count'    => 1
            ]
        );Copy

#!/usr/bin/env php
<?php
require_once __DIR__.'/vendor/autoload.php';
new \streetlamp\Statistics\StatisticsServer();Copy

<?php
//统计服务端配置
return [
     //web页面端口
     'web_port'        => 55757, 
     //接收统计数据端口
     'statistics_port' => 9200, 
     //web页面域名配置
     'host'            => ''
 ];Copy

#!/usr/bin/env php
<?php
require_once __DIR__.'/vendor/autoload.php';
new \streetlamp\Statistics\StatisticsServer("/var/www/html/application/config.php");Copy

#!/usr/bin/env php
<?php
require_once __DIR__.'/vendor/autoload.php';
$config = [
   //web页面端口
  'web_port' => 55757,
  //接收统计数据端口
  'statistics_port' => 9200,
  //web页面域名配置
  'host' => ''
];
new \streetlamp\Statistics\StatisticsServer($config);Copy