laravle 整合 thrift

1，安装thrift

https://www.cnblogs.com/sunlong88/p/9965522.html

2，生成 RPC文件

thrift -r --out ./app --gen php:server ./ThriftSource/testServer.thrift

　　

composer文件：

{
    "name": "laravel/laravel",
    "description": "The Laravel Framework.",
    "keywords": ["framework", "laravel"],
    "license": "MIT",
    "type": "project",
    "require": {
        "php": ">=5.5.9",
        "laravel/framework": "5.1.*",
        "bican/roles": "2.1.*",
        "leric/php-thrift": "0.9.*"
    },
    "require-dev": {
        "fzaninotto/faker": "~1.4",
        "mockery/mockery": "0.9.*",
        "phpunit/phpunit": "~4.0",
        "phpspec/phpspec": "~2.1"
    },
    "autoload": {
        "classmap": [
            "database",
            "app/Rpc"

        ],
        "psr-4": {
            "Entry\": "app/entry",
            "Api\": "app/api",
            "Stats\": "app/stats",
            "Rpc\": "app/Rpc",
            "Services\": "app/services"
        }
    },
    "autoload-dev": {
        "classmap": [
            "tests/TestCase.php"
        ]
    },
    "scripts": {
        "post-root-package-install": [
            "php -r "copy('.env.example', '.env');""
        ],
        "post-create-project-cmd": [
            "php artisan key:generate"
        ],
        "post-install-cmd": [
            "Illuminate\Foundation\ComposerScripts::postInstall",
            "php artisan optimize"
        ],
        "post-update-cmd": [
            "Illuminate\Foundation\ComposerScripts::postUpdate",
            "php artisan optimize"
        ]
    },
    "config": {
        "preferred-install": "dist"
    }
}

新建 EchopServie文件：

E:workspacelaravel51-serverappservicesEchopServie.php

<?php
namespace Services;
use RpcTestEchopIf;

class EchopServie implements EchopIf{
    public function Echop($str){
        Log::info($str);
        return "RPC:".$str;
    }
}

　　

3，编写服务端和客户端：

Route::post('/rpc/index', 'RpcController@index')->name('rpc.index');
Route::get('/rpc/test', 'RpcController@test')->name('rpc.test');

　　

RpcController文件

<?php namespace StatsControllers;
use IlluminateSupportFacadesAuth;
use IlluminateSupportFacadesDB as DB;
use RpcTestEchopClient;
use RpcTestEchopProcessor;
use StatsModelsTestTest;
use EntryUser;
use Request;
use ThriftExceptionTException;
use ThriftProtocolTBinaryProtocol;
use ThriftTransportTBufferedTransport;
use ThriftTransportTHttpClient;
use ThriftTransportTPhpStream;

class RpcController extends Controller
{

    public function index(Request $request)
    {
        try {
            ob_end_clean();
            header("Content-type: application/x-thrift; charset=utf-8");
            if (php_sapi_name() == 'cli') {
                echo "
";
                exit();
            }
            $handler = new ServicesEchopServie();
            $processor = new EchopProcessor($handler);
            $transport = new TBufferedTransport(new TPhpStream(TPhpStream::MODE_R | TPhpStream::MODE_W));
            $protocol = new TBinaryProtocol($transport, true, true);
            $transport->open();
            $processor->process($protocol, $protocol);
            $transport->close();
        } catch (TException $tx) {
            Log::info($tx->getMessage());
        }
    }

    public function test(Request $request)
    {
        try {
            ini_set('memory_limit', '1024M');
            $socket = new THttpClient('192.168.1.188', 8082, '/rpc/index');
            $transport = new TBufferedTransport($socket, 1024, 1024);
            $protocol = new TBinaryProtocol($transport);
            $client = new RpcTestEchopClient($protocol);
            $transport->open();
            $result = $client->Echop('hello world !');
            print_r($result);
            $transport->close();
        } catch (TException $tx) {
            print_r($tx->getMessage());
        }

    }


}

最后测试：

访问：http://192.168.1.188:8082/rpc/test

详情：https://github.com/sunlongv5/laravel-thrift