php rpc 请求 openresty 获取msgpack数据

quqiufeng

http://quqiufeng.blog.163.com/blog/static/242553014201569104927633/

服务端代码

nginx.conf

location /test

{

content_by_lua '

ngx.req.read_body()

local mp = require "MessagePack"

--local cjson = require "cjson"

local body = ngx.req.get_body_data()

local header = string.sub(body,1,82)

local package = string.sub(body,83,90)

local _body = string.sub(body,91)

local data = mp.unpack(_body)

--ngx.log(ngx.ERR,"[",cjson.encode(data),"]") 调试日志

-- 客户端传递过来的参数为

local email = data.p[1] # quqi...@gmail.com

--调用的函数名为

local _fun = data.m # 函数名为 api

local result = mp.pack({i=data.i,s="",r="quqiufeng",o="",e=""})

local sendout = table.concat({header,package,result})

ngx.print(sendout)

return

}

php代码

<?php

$client = new Yar_Client("http://localhost/test");

$client->SetOpt(YAR_OPT_PACKAGER, "msgpack");

$result = $client->api("quqi...@gmail.com");

var_dump($result);

membphis

你是在做jsonrpc相关的东西么？

我也做了一个，欢迎相互交流一下？我这个可以直接发起jsonrpc请求，不需要HTTP头。

https://github.com/membphis/lua-resty-jsonrpc

Use exmaple

Syntax:

--> data sent to Server
<-- data sent to Client

rpc call with positional parameters:

--> {"jsonrpc": "2.0", "method": "subtract", "params": [42, 23], "id": 1}
<-- {"jsonrpc": "2.0", "result": 19, "id": 1}

--> {"jsonrpc": "2.0", "method": "subtract", "params": [23, 42], "id": 2}
<-- {"jsonrpc": "2.0", "result": -19, "id": 2}

rpc call with parallels:

--> {"jsonrpc": "2.0", "method": "subtract", "params": [23, 42], "id": 1}
--> {"jsonrpc": "2.0", "method": "subtract", "params": [23, 42], "id": 2}
<-- {"jsonrpc": "2.0", "result": -19, "id": 1}
<-- {"jsonrpc": "2.0", "result": -19, "id": 2}

On Thu, Jul 9, 2015 at 2:25 PM, 瞿秋丰 <quqi...@gmail.com> wrote:

http://quqiufeng.blog.163.com/blog/static/242553014201569104927633/

服务端代码

nginx.conf

location /test
{
content_by_lua '
ngx.req.read_body()
local mp = require "MessagePack"
--local cjson = require "cjson"
local body = ngx.req.get_body_data()
local header = string.sub(body,1,82)
local package = string.sub(body,83,90)
local _body = string.sub(body,91)
local data = mp.unpack(_body)
--ngx.log(ngx.ERR,"[",cjson.encode(data),"]") 调试日志
-- 客户端传递过来的参数为
local email = data.p[1] # quqi...@gmail.com
--调用的函数名为
local _fun = data.m # 函数名为 api
local result = mp.pack({i=data.i,s="",r="quqiufeng",o="",e=""})
local sendout = table.concat({header,package,result})
ngx.print(sendout)
return
';
}

php代码

<?php
$client = new Yar_Client("http://localhost/test");
$client->SetOpt(YAR_OPT_PACKAGER, "msgpack");
$result = $client->api("quqi...@gmail.com");
var_dump($result);

--

Membhis

My github: https://github.com/membphis