这次给大家带来php与ethereum客户端交互使用详解,php与ethereum客户端交互使用的注意事项有哪些,下面就是实战案例,一起来看一下。
php与ethereum rpc server通信
一、json rpc
json rpc就是基于json的远程过程调用,这么解释比较抽象。简单来说,就是post一个json格式的数据调用rpc server中的方法. 而这个json格式是固定的, 总的来说有这么几项:
{
"method": "",
"params": [],
"id": idnumber
}
method: 方法名
params: 参数列表
id: 对过程调用的唯一标识号
二、构建一个json rpc客户端
<?php
class jsonrpcclient {
/**
* debug state
*
* @var boolean
*/
private $debug;
/**
* the server url
*
* @var string
*/
private $url;
/**
* the request id
*
* @var integer
*/
private $id;
/**
* if true, notifications are performed instead of requests
*
* @var boolean
*/
private $notification = false;
/**
* takes the connection parameters
*
* @param string $url
* @param boolean $debug
*/
public function construct($url,$debug = false) {
// server url
$this->url = $url;
// proxy
empty($proxy) ? $this->proxy = '' : $this->proxy = $proxy;
// debug state
empty($debug) ? $this->debug = false : $this->debug = true;
// message id
$this->id = 1;
}
/**
* sets the notification state of the object. in this state, notifications are performed, instead of requests.
*
* @param boolean $notification
*/
public function setrpcnotification($notification) {
empty($notification) ?
$this->notification = false
:
$this->notification = true;
}
/**
* performs a jsonrcp request and gets the results as an array
*
* @param string $method
* @param array $params
* @return array
*/
public function call($method,$params) {
// check
if (!is_scalar($method)) {
throw new exception('method name has no scalar value');
}
// check
if (is_array($params)) {
// no keys
$params = $params[0];
} else {
throw new exception('params must be given as array');
}
// sets notification or request task
if ($this->notification) {
$currentid = null;
} else {
$currentid = $this->id;
}
// prepares the request
$request = array(
'method' => $method,
'params' => $params,
'id' => $currentid
);
$request = json_encode($request);
$this->debug && $this->debug.='***** request *****'."\n".$request."\n".'***** end of request *****'."\n\n";
// performs the http post
$opts = array ('http' => array (
'method' => 'post',
'header' => 'content-type: application/json',
'content' => $request
));
$context = stream_context_create($opts);
if ($fp = fopen($this->url, 'r', false, $context)) {
$response = '';
while($row = fgets($fp)) {
$response.= trim($row)."\n";
}
$this->debug && $this->debug.='***** server response *****'."\n".$response.'***** end of server response *****'."\n";
$response = json_decode($response,true);
} else {
throw new exception('unable to connect to '.$this->url);
}
// debug output
if ($this->debug) {
echo nl2br($debug);
}
// final checks and return
if (!$this->notification) {
// check
if ($response['id'] != $currentid) {
throw new exception('incorrect response id (request id: '.$currentid.', response id: '.$response['id'].')');
}
if (!is_null($response['error'])) {
throw new exception('request error: '. var_export($response['error'], true));
}
return $response['result'];
} else {
return true;
}
}
}
?>
比较简单的代码,如果比较懒,拿过去用就行了。也可以上packagist.org自己找一个rpc client.
三、调用rpc的两类方法
有两类方法需要调用. 一类是rpc server自带方法,另一类就是合约方法.
rpc server方法调用json格式
{
"method": "eth_accounts",
"params": [],
"id": 1
}
rpc server自带方法的列表
调用自带方法比较简单,参考上述链接,大部分都有示例.
合约方法调用json格式
调用合约方法必须使用自带方法中的eth_call. 而合约方法名称和合约方法参数列表则使用params进行体现, 比如: 我们要调用合约中的balanceof方法, 则json数据应该如何构造呢?
首先看看getbalanace的函数实现:
function balanceof(address _owner) public view returns (uint256 balance)
提炼出函数原型:
balanceof(address)
在geth控制台下运行命令:
web3.sha3("balanceof(address)").substring(0, 10)
得到函数hash "0x70a08231"
假设待查询的地址 address _owner = "0x38aabef4cd283ccd5091298dedc88d27c5ec5750", 则去掉前面的"0x", 并在左边补24个零(一般地址长度为42位, 去掉'0x'后为40位),构成64位十六进制参数.
最终得到的参数为 "0x70a0823100000000000000000000000038aabef4cd283ccd5091298dedc88d27c5ec5750"
假设我们的合约地址为 "0xaeab4084194b2a425096fb583fbcd67385210ac3".
则得到最终的json数据为:
{
"method": "eth_call",
"params": [{"from": "0x38aabef4cd283ccd5091298dedc88d27c5ec5750", "to": "0xaeab4084194b2a425096fb583fbcd67385210ac3", "data": "0x70a0823100000000000000000000000038aabef4cd283ccd5091298dedc88d27c5ec5750"}, "latest"],
"id": 1
}
把以上json数据以post方式发送给服务器,就可以调用合约方法"balanceof", 查询给定的地址中的代币余额.
调用合约中的其他方法也要新遵循上面的方式, 我们再分析一下transfer方法, 加深印象:
首先, 看看代码中的函数实现:
function transfer(address _to, uint256 _value) public returns (bool)
其次, 提炼出函数原型:
transfer(address,uint256) //注意逗号后面不能有空格
再次, 在控制台运行sha3函数:
web3.sha3("transfer(address,uint256)").substring(0, 10)
得到函数hash "0xa9059cbb"
第一个参数假设 address _to = "0x38aabef4cd283ccd5091298dedc88d27c5ec5750", 则去"0x", 补零到64位.
第二个参数假设 uint256 _value = 43776, 则化为十六进制"0xab00"后, 去"0x", 补零到64位.
连接起来
"0xa9059cbb00000000000000000000000038aabef4cd283ccd5091298dedc88d27c5ec5750000000000000000000000000000000000000000000000000000000000000ab00"
构建json数据:
{
"method": "eth_call",
"params": [{"from": "0x38aabef4cd283ccd5091298dedc88d27c5ec5750", "to": "0xaeab4084194b2a425096fb583fbcd67385210ac3", "data": "0xa9059cbb00000000000000000000000038aabef4cd283ccd5091298dedc88d27c5ec5750000000000000000000000000000000000000000000000000000000000000ab00"}, "latest"],
"id": 1
}
from 转出者地址
to 合约地址
data 上述操作得到的十六进制数
把以上的步骤转化为代码.
构建一个以太坊rpc client
<?php
require './jsonrpcclient.php';
//php自带的dechex无法把大整型转换为十六进制
function bc_dechex($decimal)
{
$result = [];
while ($decimal != 0) {
$mod = $decimal % 16;
$decimal = floor($decimal / 16);
array_push($result, dechex($mod));
}
return join(array_reverse($result));
}
class ethereumrpcclient
{
public static $client = null;
//布署合约的账户地址
const coinbase = '0x38aabef4cd283ccd5091298dedc88d27c5ec5750';
//合约地址
const contract = '0xaeab4084194b2a425096fb583fbcd67385210ac3';
public static function callstatic($method, $params)
{
$params = count($params) < 1 ? [] : $params[0];
try {
if (is_null(self::$client)) {
self::$client = new jsonrpcclient('http://127.0.0.1:8545', true);
}
} catch (\exception $e) {
echo $e->getmessage();
}
return call_user_func([self::$client, $method], $params);
}
public static function getbalance($address)
{
$method_hash = '0x70a08231';
$method_param1_hex = str_pad(substr($address, 2), 64, '0', str_pad_left);
$data = $method_hash . $method_param1_hex;
$params = ['from' => $address, 'to' => self::contract, 'data' => $data];
$total_balance = self::eth_call([$params, "latest"]);
return hexdec($total_balance) / (pow(10, 18));
}
public static function transfer($to, $value)
{
self::personal_unlockaccount([self::coinbase, "123456", 3600]);
$value = bcpow(10, 18) * $value;
$method_hash = '0xa9059cbb';
$method_param1_hex =str_pad(substr($to, 2), 64, '0', str_pad_left);
$method_param2_hex = str_pad(strval(bc_dechex($value)), 64, '0', str_pad_left);
$data = $method_hash . $method_param1_hex . $method_param2_hex;
$params = ['from' => self::coinbase, 'to' => self::contract, 'data' => $data];
return self::eth_sendtransaction([$params]);
}
}
代码比较简单, 要注意几点:
transfer函数的value单位很小, 是 10 ^ -18, 所以如果你想转1000个,其实是要乘于 10的18次方, 这里的18是decimals.
由于第1点, 应该使用bcpow代替pow函数.
不能使用php自带的dechex函数. 因为dechex要求整型不能大于 php_int_max, 而这个数在32位机上为4294967295。由于第1 点, 所有的数都要乘于10的18次方, 所以得到的数要远远大于php_int_max. 建议自己实现10进制转16进制,如果你不知道如何实现,参考上述代码。
在运行某些合约方法, 比如transfer时, 要先unlock用户.
发送交易之后, 一定要在服务器端启动挖矿, 这样交易才会真的写入到区块, 比如你调用transfer之后,却发现对方没有到账,先别吃惊,启动挖矿试试。如果想启用自动挖码, 在geth --rpc ...最后加上 --mine.
测试:
<?php
var_dump(ethereumrpcclient::personal_newaccount(['password']));
var_dump(ethereumrpcclient::personal_unlockaccount([ethereumrpcclient::coinbase, "password", 3600]);
var_dump(ethereumrpcclient::getbalance("0x...."));
相信看了本文案例你已经掌握了方法,更多精彩请关注其它相关文章!
推荐阅读:
php使用file_get_contents发送http请求步骤详解
php实现随机剔除算法
以上就是php与ethereum客户端交互使用详解的详细内容。