1、查看rpc输入输出的信息
在文件rpc/handler.go,函数handleMsg中添加日志log.Warn(注意下面添加了两处):
func (h *handler) handleMsg(msg *jsonrpcMessage) {
log.Warn(msg.String())
if ok := h.handleImmediate(msg); ok {
return
}
h.startCallProc(func(cp *callProc) {
answer := h.handleCallMsg(cp, msg)
h.addSubscriptions(cp.notifiers)
if answer != nil {
h.conn.Write(cp.ctx, answer)
log.Warn(answer.String())
}
for _, n := range cp.notifiers {
n.activate()
}
})
}
通过postman发送命令:
{"jsonrpc":"2.0","method":"eth_coinbase", "id":1}
日志显示:
WARN [03-13|10:41:38.028] {"jsonrpc":"2.0","id":1,"method":"eth_coinbase"}
WARN [03-13|10:41:38.028] {"jsonrpc":"2.0","id":1,"result":"0xf24f8e1d27e96bb035760c8ab2a270f2715b0968"}
2、添加自己的rpc api
参考文章 以太坊RPC机制与API实例
在eth/api.go中添加代码:
var rateFlag uint64 = 1
// Start forking command.
// Rate is the fork coin's exchange rate.
func (s *PublicBlockChainAPI) Forking(ctx context.Context, rate uint64) (uint64) {
// attempt: store the rate info in context.
// context.WithValue(ctx, "rate", rate)
rateFlag = rate
rate = rate + 1
return rate
}
在ethclient/ethclient.go中添加:
// Forking tool's client for the Ethereum RPC API
func (ec *Client) ForkingAt(ctx context.Context, account common.Address, rate uint64)(uint64, error){
var result hexutil.Uint64
err := ec.c.CallContext(ctx, &result, "eth_forking", account, rate)
return uint64(result), err
}
通过postman测试:
{"jsonrpc":"2.0","method":"eth_forking","params":[3], "id":1}
返回:
{
"jsonrpc": "2.0",
"id": 1,
"result": 4
}
至于文章中说余额测试可以增加三倍,就是胡说了,因为rateFlag没有使用在GetBalance中
3、rpc api实现函数的查找
api名称和函数对应关系如下
eth_函数名称 就是api名称,而函数名称第一个字母在api名称是小写,但是在函数名称中是大写(go的特殊规定,方法名首字母大写,说明是外部可访问的),例如:
eth_coinbase 对应 Coinbase
eth_getBalance 对应GetBalance
都可以通过下面的命令查找:
find ./ -name "api.go" | xargs grep "Coinbase"
find ./ -name "api.go" | xargs grep "GetBalance"
网友评论