资讯专栏INFORMATION COLUMN

基于Mixin Network的PHP比特币开发教程 之一:创建机器人

Barrior / 2552人阅读

摘要:英文原文是一个免费的极速的端对端加密数字货币交易系统在本章中,你可以按教程在中创建一个来接收用户消息学到如何给机器人转比特币或者让机器人给你转比特币资源汇总课程简介创建一个接受消息的机器人机器人接受比特币并立即退还用户如何通过创建新帐号创建

英文原文

Mixin Network 是一个免费的 极速的端对端加密数字货币交易系统.
在本章中,你可以按教程在Mixin Messenger中创建一个bot来接收用户消息, 学到如何给机器人转比特币 或者 让机器人给你转比特币.

Mixin network 资源汇总

课程简介

创建一个接受消息的机器人

机器人接受比特币并立即退还用户

如何通过Mixin Network API创建新帐号

创建一个接受消息的机器人

通过本教程,你将学会如何用PHP创建一个机器人APP,让它能接受消息.

PHP 环境安装:

本教程的程序基于PHP 7开发,所以你需要先安装PHP7.2/PHP7.3与composer, 其中,composer是PHP的包管理系统!

on macOS
brew update
brew install php@7.2
php -r "copy("https://getcomposer.org/installer", "composer-setup.php");"
php -r "if (hash_file("sha384", "composer-setup.php") === "48e3236262b34d30969dca3c37281b3b4bbe3221bda826ac6a9a62d6444cdb0dcd0615698a5cbe587c3f0fe57a54d8f5") { echo "Installer verified"; } else { echo "Installer corrupt"; unlink("composer-setup.php"); } echo PHP_EOL;"
//将PHP安装到/usr/local/opt/php@7.2/bin 目录,并取一个简单的各字:composer
php composer-setup.php --install-dir=/usr/local/opt/php@7.2/bin --filename=composer
php -r "unlink("composer-setup.php");"

如果之前你安装过php 7.1 或者更旧的php版本,执行brew unlink php@7.1删除这些链接,然后再执行brew link php@7.3将php 7.3链接到php.

wenewzha:mixin_labs-php-bot wenewzhang$ brew unlink php@7.1
Unlinking /usr/local/Cellar/php/7.1.23... 24 symlinks removed
wenewzha:mixin_labs-php-bot wenewzhang$ brew link php@7.3
Warning: php@7.3 is keg-only and must be linked with --force

If you need to have this software first in your PATH instead consider running:
  echo "export PATH="/usr/local/opt/php@7.3/bin:$PATH"" >> ~/.bash_profile
  echo "export PATH="/usr/local/opt/php@7.3/sbin:$PATH"" >> ~/.bash_profile

之后,根据你的系统实际情况,看看php -v能不能执行成功,如果不行,将默认的PATH设置并保存到.bash_profile.

echo "export PATH="/usr/local/opt/php@7.3/bin:$PATH"" >> ~/.bash_profile
echo "export PATH="/usr/local/opt/php@7.3/sbin:$PATH"" >> ~/.bash_profile
source ~/.bash_profile
on Ubuntu
apt update
apt upgrade

//install php 7.2
apt-get install software-properties-common python-software-properties
add-apt-repository -y ppa:ondrej/php
apt-get update
apt-get install php7.2 php7.2-cli php7.2-common
//install composer
php -r "copy("https://getcomposer.org/installer", "composer-setup.php");"
php -r "if (hash_file("sha384", "composer-setup.php") === "48e3236262b34d30969dca3c37281b3b4bbe3221bda826ac6a9a62d6444cdb0dcd0615698a5cbe587c3f0fe57a54d8f5") { echo "Installer verified"; } else { echo "Installer corrupt"; unlink("composer-setup.php"); } echo PHP_EOL;"
//将PHP安装到/usr/local/opt/php@7.2/bin 目录,并取一个简单的各字:composer
php composer-setup.php --install-dir=/usr/local/bin --filename=composer
php -r "unlink("composer-setup.php");"

最新的Composer在这儿Composer
请确保PHP与composer安装在$PATH包含的目录之内,直接运行php -vcomposer -V 就可以检查出来,如果提示如下,表示安装正确!

wenewzha:minecraft wenewzhang$ php -v
PHP 7.2.13 (cli) (built: Dec  7 2018 10:41:23) ( NTS )
Copyright (c) 1997-2018 The PHP Group
Zend Engine v3.2.0, Copyright (c) 1998-2018 Zend Technologies
    with Zend OPcache v7.2.13, Copyright (c) 1999-2018, by Zend Technologies
wenewzha:minecraft wenewzhang$ composer -V
Composer version 1.8.0 2018-12-03 10:31:16

如果提示command not found,表示bash没有在$PATH下找到php,请重复以上的安装步骤!

wenewzha:mixin_network-nodejs-bot2 wenewzhang$ php -v
-bash: php: command not found
创建你的项目

到你的工作文档中,创建一个目录,并取一个名字,比如:mixin_labs-php-bot

mkdir mixin_labs-php-bot
cd mixin_labs-php-bot

转到新创建的项目目录下, 执行 composer init, 依提示完成 composer.json的创建,

root@iZj6cbmqen2lqp7l48nfgkZ:~/mixin_labs-php-bot# composer init
 Welcome to the Composer config generator
This command will guide you through creating your composer.json config.
Package name (/) [user/mixin_labs-php-bot]:
Description []: PHP 7 bot for Mixin Messenger
Author [, n to skip]: JimmyZhang 
Minimum Stability []:
Package Type (e.g. library, project, metapackage, composer-plugin) []:
License []:
Define your dependencies.
Would you like to define your dependencies (require) interactively [yes]? no
Would you like to define your dev dependencies (require-dev) interactively [yes]? no
{
   "name": "user/mixin_labs-php-bot",
   "description": "PHP 7 bot for Mixin Messenger",
   "authors": [
       {
           "name": "JimmyZhang",
           "email": "this-a-email-address@nodomain.com"
       }
   ],
   "require": {}
}
Do you confirm generation [yes]? yes

本教程引用了 mixin-sdk-php 与 Ratchet pawl, mixin-sdk-php 是一个Mixin Network PHP SDK , Ratchet pawl 是一个WebSocket客户端.
打开composer.json, 在"require"增加两行引用:

"require": {
    "exinone/mixin-sdk-php": "^1.1",
    "ratchet/pawl": "^0.3.3",
},

保存composer.json后,执行 composer install 来下载:

composer install

下载完成后,目录下会出现一个vendor的子目录。

root@iZj6cbmqen2lqp7l48nfgkZ:~/mixin_labs-php-bot# ls
composer.json  composer.lock  vendor

如果你是git克隆的源代码,直接执行 composer install 来下载依赖包。

创建第一个机器人APP

按下面的提示,到mixin.one创建一个APPtutorial.

生成相应的参数

记下这些生成的参数
它们将用于config.php中.


在项目目录下,创建config.php,将生成的参数,替换成你的!

config.php
return [
    "mixin_id"      => "7000101716",
    "client_id"     => "a1ce2967-a534-417d-bf12-c86571e4eefa",
    "client_secret" => "7339866727d24eeec1c4ebb6c634fd25a7b9057ee6d5939cca9b6b9fc15f4d1f",
    "pin"           => "512772",
    "pin_token"     => "abRdNq6soRALRG434IgR7WS/qP7LOcpfviqSfWfABdIKyZGLnWXFMrVCHpChIkBRGRAcsUguni0OoNsShddPVL3qoD5fxbF5dRUiRv14urH1Pmdl6zIZdCH159QMr5wLmmSHSGu2AihNkUHUo3bAJsrvOW0nke5y6R5YE/pNNfo=",
    "session_id"    => "51faabbf-48ff-4df2-898d-e9b318afae35",
    "private_key"   => <<

需要替换的参数包括: mixin_id, client_id, client_secret, and the pin, pin token, session_id, private key.

经典的Hello world

在项目目录下创建一个app.php文件,将下面的代码拷进去:

 15
]);
$connector = new RatchetClientConnector($loop,$reactConnector);
class callTraitClass {
  use MixinSDKTrait;
  public $config;
  public function __construct()
  {
      $config = require(__DIR__."/config.php");
      $this->config        = $config;
  }
}
$callTrait = new callTraitClass();
$Token = $callTrait->getToken("GET", "/", "");
// $connector("ws://127.0.0.1:9000", ["protocol" => "Mixin-Blaze-1"], ["Origin" => "http://localhost",
$connector("wss://blaze.mixin.one", ["protocol" => "Mixin-Blaze-1"],[
                                    "Authorization" => "Bearer ".$Token
                                      ])
->then(function(RatchetClientWebSocket $conn) {
    $conn->on("message", function(RatchetRFC6455MessagingMessageInterface $msg) use ($conn) {
        $jsMsg = json_decode(gzdecode($msg));
        print_r($jsMsg);
        if ($jsMsg->action === "CREATE_MESSAGE" and property_exists($jsMsg,"data")) {
          echo "
Need reply server a receipt!
";
          $RspMsg = generateReceipt($jsMsg->data->message_id);
          $msg = new Frame(gzencode(json_encode($RspMsg)),true,Frame::OP_BINARY);
          $conn->send($msg);

          if ($jsMsg->data->category === "PLAIN_TEXT") {
                $msgData = sendPlainText($jsMsg->data->conversation_id,
                                          base64_decode($jsMsg->data->data));
                $msg = new Frame(gzencode(json_encode($msgData)),true,Frame::OP_BINARY);
                $conn->send($msg);
          } //end of PLAIN_TEXT
        } //end of CREATE_MESSAGE

    });
    $conn->on("close", function($code = null, $reason = null) {
        echo "Connection closed ({$code} - {$reason})
";
    });
/*                   start listen for the incoming message          */
    $message = [
        "id"     => Uuid::uuid4()->toString(),
        "action" => "LIST_PENDING_MESSAGES",
    ];
    print_r(json_encode($message));
    $msg = new Frame(gzencode(json_encode($message)),true,Frame::OP_BINARY);
    $conn->send($msg);
    // $conn->send(gzencode($msg,1,FORCE_DEFLATE));
}, function(Exception $e) use ($loop) {
    echo "Could not connect: {$e->getMessage()}
";
    $loop->stop();
});

$loop->run();


function sendPlainText($conversation_id,$msgContent):Array {

   $msgParams = [
     "conversation_id" => $conversation_id,
     "category"        => "PLAIN_TEXT",
     "status"          => "SENT",
     "message_id"      => Uuid::uuid4()->toString(),
     "data"            => base64_encode($msgContent),//base64_encode("hello!"),
   ];
   $msgPayButton = [
     "id"     =>  Uuid::uuid4()->toString(),
     "action" =>  "CREATE_MESSAGE",
     "params" =>   $msgParams,
   ];
   return $msgPayButton;
}

function generateReceipt($msgID):Array {
  $IncomingMsg = ["message_id" => $msgID, "status" => "READ"];
  $RspMsg = ["id" => Uuid::uuid4()->toString(), "action" => "ACKNOWLEDGE_MESSAGE_RECEIPT",
              "params" => $IncomingMsg];
  return $RspMsg;
}

保存,并在终端里执行app.php

php app.php

如果一切正常,提示如下:

wenewzha:mixin_labs-php-bot wenewzhang$ php app.php
a1ce2967-a534-417d-bf12-c86571e4eefa{"id":"4454b6c5-4a89-440c-bd22-7a79cf4954ca","action":"LIST_PENDING_MESSAGES"}stdClass Object
(
    [id] => 4454b6c5-4a89-440c-bd22-7a79cf4954ca
    [action] => LIST_PENDING_MESSAGES
)

在手机安装 Mixin Messenger,增加机器人为好友,(比如这个机器人是7000101639) 然后发送消息给它,效果如下!

源代码解释

WebSocket是建立在TCP基础之上的全双工通讯方式,我们需要建立一个loop循环来维持通迅。

$loop = ReactEventLoopFactory::create();
$reactConnector = new ReactSocketConnector($loop, [
    "timeout" => 15
]);
$connector = new RatchetClientConnector($loop,$reactConnector);

机器人APP通过Mixin Messenger服务器来接收用户发过来的消息,连接服务器,需要Token来验证用户的身份,
详细资料可参考如下链接:
Token认证, 接收服务器消息

mixin-sdk-php 实现了令牌Token的生成(getToken), 调用代码如下:

class callTraitClass {
  use MixinSDKTrait;
  public $config;
  public function __construct()
  {
      $config = require(__DIR__."/config.php");
      $this->config        = $config;
  }
}
$callTrait = new callTraitClass();
$Token = $callTrait->getToken("GET", "/", "");

连接到服务器,注意协议类型与Token:

$connector("wss://blaze.mixin.one", ["protocol" => "Mixin-Blaze-1"],[
                                    "Authorization" => "Bearer ".$Token
                                      ])

向服务器发送"LIST_PENDING_MESSAGES",这样服务器才会将收到的消息发送给机器人APP.

/*                   start listen for the incoming message          */
    $message = [
        "id"     => Uuid::uuid4()->toString(),
        "action" => "LIST_PENDING_MESSAGES",
    ];
    print_r(json_encode($message));
    $msg = new Frame(gzencode(json_encode($message)),true,Frame::OP_BINARY);
    $conn->send($msg);

增加侦听 onMessage 接收并分析消息:

->then(function(RatchetClientWebSocket $conn) {
    $conn->on("message", function(RatchetRFC6455MessagingMessageInterface $msg) use ($conn) {
        $jsMsg = json_decode(gzdecode($msg));
        print_r($jsMsg);
        if ($jsMsg->action === "CREATE_MESSAGE" and property_exists($jsMsg,"data")) {
          echo "
Need reply server a receipt!
";
          $RspMsg = generateReceipt($jsMsg->data->message_id);
          $msg = new Frame(gzencode(json_encode($RspMsg)),true,Frame::OP_BINARY);
          $conn->send($msg);

          if ($jsMsg->data->category === "PLAIN_TEXT") {
                $msgData = sendPlainText($jsMsg->data->conversation_id,
                                          base64_decode($jsMsg->data->data));
                $msg = new Frame(gzencode(json_encode($msgData)),true,Frame::OP_BINARY);
                $conn->send($msg);
          } //end of PLAIN_TEXT
        } //end of CREATE_MESSAGE

    });
    $conn->on("close", function($code = null, $reason = null) {
        echo "Connection closed ({$code} - {$reason})
";
    });                                      

Mixin Messenger支持的消息类型很多,具体可到下面链接查看: WebSocket消息类型.

每接收到一个消息,需要按消息编号(message_id)给服务器回复一个"已读"的消息,避免服务器在机器人重新登入后,再次发送处理过的消息!

echo "
Need reply server a receipt!
";
$RspMsg = generateReceipt($jsMsg->data->message_id);
$msg = new Frame(gzencode(json_encode($RspMsg)),true,Frame::OP_BINARY);
$conn->send($msg);

function generateReceipt($msgID):Array {
  $IncomingMsg = ["message_id" => $msgID, "status" => "READ"];
  $RspMsg = ["id" => Uuid::uuid4()->toString(), "action" => "ACKNOWLEDGE_MESSAGE_RECEIPT",
              "params" => $IncomingMsg];
  return $RspMsg;
}
完成

现在你的机器人APP运行起来了,你打算如何改造你的机器人呢?

完整的代码在这儿

下一课机器人接收与处理加密货币

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/24575.html

相关文章

  • 基于Mixin NetworkPHP比特开发教程 之一创建器人

    摘要:英文原文是一个免费的极速的端对端加密数字货币交易系统在本章中,你可以按教程在中创建一个来接收用户消息学到如何给机器人转比特币或者让机器人给你转比特币资源汇总课程简介创建一个接受消息的机器人机器人接受比特币并立即退还用户如何通过创建新帐号创建 英文原文 Mixin Network 是一个免费的 极速的端对端加密数字货币交易系统.在本章中,你可以按教程在Mixin Messenger中创建...

    Gemini 评论0 收藏0
  • 基于Mixin NetworkPHP比特开发教程: 器人接受比特并立即退还用户

    摘要:如果机器人收到币,大于零如果机器人支付币给用户,接收到的消息是一样的,唯一不同的是是一个负数最后一步,调用将币还给用户完整的代码在这儿 showImg(https://segmentfault.com/img/remote/1460000018419614?w=1200&h=659); 在 上一篇教程中, 我们创建了自动回复消息的机器人,当用户发送消息Hello,World!时,机器人...

    import. 评论0 收藏0
  • 基于Mixin NetworkPHP比特开发教程: 器人接受比特并立即退还用户

    摘要:如果机器人收到币,大于零如果机器人支付币给用户,接收到的消息是一样的,唯一不同的是是一个负数最后一步,调用将币还给用户完整的代码在这儿 showImg(https://segmentfault.com/img/remote/1460000018419614?w=1200&h=659); 在 上一篇教程中, 我们创建了自动回复消息的机器人,当用户发送消息Hello,World!时,机器人...

    winterdawn 评论0 收藏0
  • 基于Mixin NetworkPHP比特开发教程: 创建比特钱包

    摘要:我们已经创建过一个回复消息的机器人和一个能自动支付比特币的机器人通过本教程的学习,你可以学到如下内容如何创建一个比特币钱包如何读取比特币钱包的余额如何支付比特币并即时确认如何将的比特币提现到你的冷钱包或第三方交易所前期准备你要有一个账户。 showImg(https://github.com/wenewzhang/mixin_labs-php-bot/raw/master/Bitcoi...

    DangoSky 评论0 收藏0
  • 基于Mixin NetworkPHP比特开发教程: 创建比特钱包

    摘要:我们已经创建过一个回复消息的机器人和一个能自动支付比特币的机器人通过本教程的学习,你可以学到如下内容如何创建一个比特币钱包如何读取比特币钱包的余额如何支付比特币并即时确认如何将的比特币提现到你的冷钱包或第三方交易所前期准备你要有一个账户。 showImg(https://github.com/wenewzhang/mixin_labs-php-bot/raw/master/Bitcoi...

    kycool 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<