• 售前

  • 售后

热门帖子
入门百科

详解php与ethereum客户端交互

[复制链接]
123457294 显示全部楼层 发表于 2021-10-25 20:12:41 |阅读模式 打印 上一主题 下一主题
php与ethereum rpc server通讯

一、Json RPC

Json RPC就是基于json的长途过程调用,这么表明比力抽象。简单来说,就是post一个json格式的数据调用rpc server中的方法. 而这个json格式是固定的, 总的来说有这么几项:
  1. {
  2.   "method": "",
  3.   "params": [],
  4.   "id": idNumber
  5. }
复制代码
      
  • method: 方法名  
  • params: 参数列表  
  • id: 对过程调用的唯一标识号
二、构建一个Json RPC客户端
  1. <?php
  2. class jsonRPCClient {
  3.   
  4.   /**
  5.    * Debug state
  6.    *
  7.    * @var boolean
  8.    */
  9.   private $debug;
  10.   
  11.   /**
  12.    * The server URL
  13.    *
  14.    * @var string
  15.    */
  16.   private $url;
  17.   /**
  18.    * The request id
  19.    *
  20.    * @var integer
  21.    */
  22.   private $id;
  23.   /**
  24.    * If true, notifications are performed instead of requests
  25.    *
  26.    * @var boolean
  27.    */
  28.   private $notification = false;
  29.   
  30.   /**
  31.    * Takes the connection parameters
  32.    *
  33.    * @param string $url
  34.    * @param boolean $debug
  35.    */
  36.   public function __construct($url,$debug = false) {
  37.     // server URL
  38.     $this->url = $url;
  39.     // proxy
  40.     empty($proxy) ? $this->proxy = '' : $this->proxy = $proxy;
  41.     // debug state
  42.     empty($debug) ? $this->debug = false : $this->debug = true;
  43.     // message id
  44.     $this->id = 1;
  45.   }
  46.   
  47.   /**
  48.    * Sets the notification state of the object. In this state, notifications are performed, instead of requests.
  49.    *
  50.    * @param boolean $notification
  51.    */
  52.   public function setRPCNotification($notification) {
  53.     empty($notification) ?
  54.               $this->notification = false
  55.               :
  56.               $this->notification = true;
  57.   }
  58.   
  59.   /**
  60.    * Performs a jsonRCP request and gets the results as an array
  61.    *
  62.    * @param string $method
  63.    * @param array $params
  64.    * @return array
  65.    */
  66.   public function __call($method,$params) {
  67.    
  68.     // check
  69.     if (!is_scalar($method)) {
  70.       throw new Exception('Method name has no scalar value');
  71.     }
  72.    
  73.     // check
  74.     if (is_array($params)) {
  75.       // no keys
  76.       $params = $params[0];
  77.     } else {
  78.       throw new Exception('Params must be given as array');
  79.     }
  80.    
  81.     // sets notification or request task
  82.     if ($this->notification) {
  83.       $currentId = NULL;
  84.     } else {
  85.       $currentId = $this->id;
  86.     }
  87.    
  88.     // prepares the request
  89.     $request = array(
  90.             'method' => $method,
  91.             'params' => $params,
  92.             'id' => $currentId
  93.             );
  94.     $request = json_encode($request);
  95.     $this->debug && $this->debug.='***** Request *****'."\n".$request."\n".'***** End Of request *****'."\n\n";
  96.     // performs the HTTP POST
  97.     $opts = array ('http' => array (
  98.               'method' => 'POST',
  99.               'header' => 'Content-type: application/json',
  100.               'content' => $request
  101.               ));
  102.     $context = stream_context_create($opts);
  103.     if ($fp = fopen($this->url, 'r', false, $context)) {
  104.       $response = '';
  105.       while($row = fgets($fp)) {
  106.         $response.= trim($row)."\n";
  107.       }
  108.       $this->debug && $this->debug.='***** Server response *****'."\n".$response.'***** End of server response *****'."\n";
  109.       $response = json_decode($response,true);
  110.     } else {
  111.       throw new Exception('Unable to connect to '.$this->url);
  112.     }
  113.    
  114.     // debug output
  115.     if ($this->debug) {
  116.       echo nl2br($debug);
  117.     }
  118.    
  119.     // final checks and return
  120.     if (!$this->notification) {
  121.       // check
  122.       if ($response['id'] != $currentId) {
  123.         throw new Exception('Incorrect response id (request id: '.$currentId.', response id: '.$response['id'].')');
  124.       }
  125.       if (!is_null($response['error'])) {
  126.         throw new Exception('Request error: '. var_export($response['error'], true));
  127.       }
  128.       
  129.       return $response['result'];
  130.       
  131.     } else {
  132.       return true;
  133.     }
  134.   }
  135. }
  136. ?>
复制代码
比力简单的代码,如果比力懒,拿过去用就行了。也可以上packagist.org自己找一个rpc client.
三、调用RPC的两类方法

有两类方法必要调用. 一类是RPC server自带方法,另一类就是合约方法.
RPC server方法调用json格式
  1. {
  2.   "method": "eth_accounts",
  3.   "params": [],
  4.   "id": 1
  5. }
复制代码
RPC Server自带方法的列表
调用自带方法比力简单,参考上述链接,大部门都有示例.
合约方法调用json格式

调用合约方法必须使用自带方法中的eth_call. 而合约方法名称和合约方法参数列表则使用params举行体现, 比如: 我们要调用合约中的balanceOf方法, 则json数据应该怎样构造呢?
首先看看getBalanace的函数实现:
  1. function balanceOf(address _owner) public view returns (uint256 balance)
复制代码
提炼出函数原型:
  1. balanceOf(address)
复制代码
在geth控制台下运行下令:
  1. web3.sha3("balanceOf(address)").substring(0, 10)
复制代码
得到函数hash "0x70a08231"
假设待查询的地点 address _owner = "0x38aabef4cd283ccd5091298dedc88d27c5ec5750", 则去掉前面的"0x", 并在左边补24个零(一样寻常地点长度为42位, 去掉'0x'后为40位),构成64位十六进制参数.
终极得到的参数为 "0x70a0823100000000000000000000000038aabef4cd283ccd5091298dedc88d27c5ec5750"
假设我们的合约地点为 "0xaeab4084194B2a425096fb583Fbcd67385210ac3".
则得到终极的json数据为:
  1. {
  2.   "method": "eth_call",
  3.   "params": [{"from": "0x38aabef4cd283ccd5091298dedc88d27c5ec5750", "to": "0xaeab4084194B2a425096fb583Fbcd67385210ac3", "data": "0x70a0823100000000000000000000000038aabef4cd283ccd5091298dedc88d27c5ec5750"}, "latest"],
  4.   "id": 1
  5. }
复制代码
把以上json数据以post方式发送给服务器,就可以调用合约方法"balanceOf", 查询给定的地点中的代币余额.
调用合约中的其他方法也要新遵照上面的方式, 我们再分析一下transfer方法, 加深印象:
首先, 看看代码中的函数实现:
  1. function transfer(address _to, uint256 _value) public returns (bool)
复制代码
其次, 提炼出函数原型:
  1. transfer(address,uint256) //注意逗号后面不能有空格
复制代码
再次, 在控制台运行sha3函数:
  1. web3.sha3("transfer(address,uint256)").substring(0, 10)
复制代码
得到函数hash "0xa9059cbb"
第一个参数假设 address _to = "0x38aabef4cd283ccd5091298dedc88d27c5ec5750", 则去"0x", 补零到64位.

第二个参数假设 uint256 _value = 43776, 则化为十六进制"0xab00"后, 去"0x", 补零到64位.
连接起来
"0xa9059cbb00000000000000000000000038aabef4cd283ccd5091298dedc88d27c5ec5750000000000000000000000000000000000000000000000000000000000000ab00"
构建json数据:
  1. {
  2.   "method": "eth_call",
  3.   "params": [{"from": "0x38aabef4cd283ccd5091298dedc88d27c5ec5750", "to": "0xaeab4084194B2a425096fb583Fbcd67385210ac3", "data": "0xa9059cbb00000000000000000000000038aabef4cd283ccd5091298dedc88d27c5ec5750000000000000000000000000000000000000000000000000000000000000ab00"}, "latest"],
  4.   "id": 1
  5. }
复制代码
      
  • from 转出者地点  
  • to 合约地点  
  • data 上述操纵得到的十六进制数
把以上的步骤转化为代码.
构建一个以太坊RPC client
  1. <?php
  2. require './jsonRPCClient.php';
  3. //php自带的dechex无法把大整型转换为十六进制
  4. function bc_dechex($decimal)
  5. {
  6.   $result = [];
  7.   while ($decimal != 0) {
  8.     $mod = $decimal % 16;
  9.     $decimal = floor($decimal / 16);
  10.     array_push($result, dechex($mod));   
  11.   }
  12.   return join(array_reverse($result));
  13. }
  14. class EthereumRPCClient
  15. {
  16.   public static $client = null;
  17.   
  18.   //布署合约的账户地址
  19.   const COINBASE = '0x38aabef4cd283ccd5091298dedc88d27c5ec5750';
  20.   
  21.   //合约地址
  22.   const CONTRACT = '0xaeab4084194B2a425096fb583Fbcd67385210ac3';
  23.   public static function __callStatic($method, $params)
  24.   {
  25.     $params = count($params) < 1 ? [] : $params[0];
  26.     try {
  27.       if (is_null(self::$client)) {
  28.         self::$client = new jsonRPCClient('http://127.0.0.1:8545', true);  
  29.       }
  30.     } catch (\Exception $e) {
  31.       echo $e->getMessage();
  32.     }
  33.     return call_user_func([self::$client, $method], $params);
  34.   }
  35.   public static function getBalance($address)
  36.   {
  37.     $method_hash = '0x70a08231';
  38.     $method_param1_hex = str_pad(substr($address, 2), 64, '0', STR_PAD_LEFT);
  39.     $data = $method_hash . $method_param1_hex;
  40.     $params = ['from' => $address, 'to' => self::CONTRACT, 'data' => $data];
  41.     $total_balance = self::eth_call([$params, "latest"]);
  42.     return hexdec($total_balance) / (pow(10, 18));
  43.   }
  44.   public static function transfer($to, $value)
  45.   {
  46.     self::personal_unlockAccount([self::COINBASE, "123456", 3600]);
  47.     $value = bcpow(10, 18) * $value;
  48.     $method_hash = '0xa9059cbb';
  49.     $method_param1_hex =str_pad(substr($to, 2), 64, '0', STR_PAD_LEFT);  
  50.     $method_param2_hex = str_pad(strval(bc_dechex($value)), 64, '0', STR_PAD_LEFT);
  51.     $data = $method_hash . $method_param1_hex . $method_param2_hex;
  52.     $params = ['from' => self::COINBASE, 'to' => self::CONTRACT, 'data' => $data];
  53.     return self::eth_sendTransaction([$params]);
  54.   }
  55. }
复制代码
代码比力简单, 要留意几点:
      
  • 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.
测试:
  1. <?php
  2. var_dump(EthereumRPCClient::personal_newAccount(['password']));
  3. var_dump(EthereumRPCClient::personal_unlockAccount([EthereumRPCClient::COINBASE, "password", 3600]);
  4. var_dump(EthereumRPCClient::getBalance("0x...."));
复制代码

帖子地址: 

回复

使用道具 举报

分享
推广
火星云矿 | 预约S19Pro,享500抵1000!
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

草根技术分享(草根吧)是全球知名中文IT技术交流平台,创建于2021年,包含原创博客、精品问答、职业培训、技术社区、资源下载等产品服务,提供原创、优质、完整内容的专业IT技术开发社区。
  • 官方手机版

  • 微信公众号

  • 商务合作