ตัวอย่างบางส่วน

ตัวอย่างที่หนึ่ง

การกำหนดโปรโตคอล

• หัวข้อมูลยาว 10 ไบต์ใช้สำหรับบันทึกความยาวทั้งหมดของแพ็กเกจข้อมูล หากจำนวนบิตไม่พอให้เติม 0
• รูปแบบข้อมูลเป็น xml

ตัวอย่างแพ็กเกจข้อมูล

0000000121<?xml version="1.0" encoding="ISO-8859-1"?>
<request>
    <module>user</module>
    <action>getInfo</action>
</request>

โดยที่ 0000000121 แทนความยาวรวมของแพ็กเกจข้อมูล ในภายหลังตามด้วยเนื้อหาของแพ็กเกจในรูปแบบข้อมูล xml

การใช้งานโปรโตคอล

namespace Protocols;
class XmlProtocol
{
    public static function input($recv_buffer)
    {
        if(strlen($recv_buffer) < 10)
        {
            // ไม่ถึง 10 ไบต์ ส่งกลับ 0 เพื่อรอข้อมูลต่อไป
            return 0;
        }
        // ส่งกลับความยาวแพ็กเกจ ความยาวแพ็กเกจรวมถึงความยาวข้อมูลในส่วนหัว + ความยาวในส่วนเนื้อหา
        $total_len = base_convert(substr($recv_buffer, 0, 10), 10, 10);
        return $total_len;
    }

    public static function decode($recv_buffer)
    {
        // แพ็กเกจข้อมูลคำขอ
        $body = substr($recv_buffer, 10);
        return simplexml_load_string($body);
    }

    public static function encode($xml_string)
    {
        // ความยาวของส่วนเนื้อหา + ส่วนหัว
        $total_length = strlen($xml_string) + 10;
        // ส่วนความยาวเติมให้ครบ 10 ไบต์ หากจำนวนบิตไม่พอให้เติม 0
        $total_length_str = str_pad($total_length, 10, '0', STR_PAD_LEFT);
        // ส่งกลับข้อมูล
        return $total_length_str . $xml_string;
    }
}

ตัวอย่างที่สอง

การกำหนดโปรโตคอล

• หัวข้อมูลยาว 4 ไบต์ในลำดับไบต์ของเครือข่ายเป็น unsigned int โดยหมายถึงความยาวของแพ็กเกจทั้งหมด
• ส่วนข้อมูลเป็นสตริง Json

ตัวอย่างแพ็กเกจข้อมูล

****{"type":"message","content":"hello all"}

โดยที่หัวข้อมูลสี่ไบต์ที่เป็น * แทนข้อมูล unsigned int ในลำดับไบต์ของเครือข่าย เป็นอักขระที่มองไม่เห็น ตามมาด้วยสตริง Json ของข้อมูลในแพ็กเกจ

การใช้งานโปรโตคอล

namespace Protocols;
class JsonInt
{
    public static function input($recv_buffer)
    {
        // ข้อมูลที่ได้รับยังไม่ถึง 4 ไบต์ ไม่สามารถทราบความยาวของแพ็กเกจได้ จึงส่งกลับ 0 เพื่อต่อสู้ข้อมูล
        if(strlen($recv_buffer) < 4)
        {
            return 0;
        }
        // ใช้ฟังก์ชัน unpack เพื่อแปลงหัวข้อมูล 4 ไบต์เป็นตัวเลข โดยหัว data 4 ไบต์ เป็นความยาวของแพ็กเกจทั้งหมด
        $unpack_data = unpack('Ntotal_length', $recv_buffer);
        return $unpack_data['total_length'];
    }

    public static function decode($recv_buffer)
    {
        // ลบหัวข้อมูล 4 ไบต์ ออกไป เพื่อให้ได้ข้อมูล Json
        $body_json_str = substr($recv_buffer, 4);
        // แปล json
        return json_decode($body_json_str, true);
    }

    public static function encode($data)
    {
        // แปลเป็น Json เพื่อสร้างเนื้อหา
        $body_json_str = json_encode($data);
        // คำนวณความยาวทั้งหมดของแพ็กเกจ หัวข้อมูล 4 ไบต์ + จำนวนไบต์ในส่วนเนื้อหา
        $total_length = 4 + strlen($body_json_str);
        // ส่งกลับข้อมูลแพ็กเกจ
        return pack('N', $total_length) . $body_json_str;
    }
}

ตัวอย่างที่สาม (ใช้โปรโตคอลไบนารีในการอัปโหลดไฟล์)

การกำหนดโปรโตคอล

struct
{
  unsigned int total_len;  // ความยาวทั้งหมดของแพ็กเกจอยู่ในลำดับไบต์ของเครือข่าย
  char         name_len;   // ความยาวของชื่อไฟล์
  char         name[name_len]; // ชื่อไฟล์
  char         file[total_len - BinaryTransfer::PACKAGE_HEAD_LEN - name_len]; // ข้อมูลไฟล์
}

ตัวอย่างโปรโตคอล

 *****logo.png****************** 

โดยที่หัวข้อมูลสี่ไบต์ที่เป็น * แทนข้อมูล unsigned int ในลำดับไบต์ของเครือข่าย เป็นอักขระที่มองไม่เห็น ไฟล์ชื่อถูกจัดเก็บในไบต์ที่ 5 และตามมาด้วยชื่อไฟล์และโครงสร้างข้อมูลไบนารีไฟล์ต้นฉบับ

การใช้งานโปรโตคอล

namespace Protocols;
class BinaryTransfer
{
    // ความยาวของส่วนหัวโปรโตคอล
    const PACKAGE_HEAD_LEN = 5;

    public static function input($recv_buffer)
    {
        // หากไม่มีความยาวของส่วนหัวโปรโตคอลเพียงพอ ให้รอไปต่อ
        if(strlen($recv_buffer) < self::PACKAGE_HEAD_LEN)
        {
            return 0;
        }
        // แพ็กข้อมูล
        $package_data = unpack('Ntotal_len/Cname_len', $recv_buffer);
        // ส่งกลับความยาวแพ็กเกจ
        return $package_data['total_len'];
    }

    public static function decode($recv_buffer)
    {
        // แพ็กข้อมูล
        $package_data = unpack('Ntotal_len/Cname_len', $recv_buffer);
        // ความยาวของชื่อไฟล์
        $name_len = $package_data['name_len'];
        // ตัดชื่อไฟล์จากการไหลของข้อมูล
        $file_name = substr($recv_buffer, self::PACKAGE_HEAD_LEN, $name_len);
        // ตัดข้อมูลไฟล์ไบนารีจากการไหลของข้อมูล
        $file_data = substr($recv_buffer, self::PACKAGE_HEAD_LEN + $name_len);
         return array(
             'file_name' => $file_name,
             'file_data' => $file_data,
         );
    }

    public static function encode($data)
    {
        // สามารถแก้ไขตามต้องการเพื่อเข้ารหัสข้อมูลที่ส่งให้กับคลายเอนต์ ในที่นี้เพียงส่งกลับข้อมูลตามต้นฉบับ
        return $data;
    }
}

ตัวอย่างการใช้งานโปรโตคอลบนเซิร์ฟเวอร์

use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('BinaryTransfer://0.0.0.0:8333');
// บันทึกไฟล์ใน tmp
$worker->onMessage = function(TcpConnection $connection, $data)
{
    $save_path = '/tmp/'.$data['file_name'];
    file_put_contents($save_path, $data['file_data']);
    $connection->send("upload success. save path $save_path");
};

Worker::runAll();

ไคลเอนต์ไฟล์ client.php (ใช้ php จำลองการอัปโหลดของไคลเอนต์)

<?php
/** ไคลเอนต์อัปโหลดไฟล์ **/
// ที่อยู่ในการอัปโหลด
$address = "127.0.0.1:8333";
// ตรวจสอบพารามิเตอร์เส้นทางไฟล์อัปโหลด
if(!isset($argv[1]))
{
   exit("ใช้ php client.php \$file_path\n");
}
// เส้นทางไฟล์ที่อัปโหลด
$file_to_transfer = trim($argv[1]);
// ไม่พบไฟล์ในระบบ
if(!is_file($file_to_transfer))
{
    exit("$file_to_transfer not exist\n");
}
// สร้างการเชื่อมต่อ socket
$client = stream_socket_client($address, $errno, $errmsg);
if(!$client)
{
    exit("$errmsg\n");
}
// ตั้งค่าให้เป็นบล็อก
stream_set_blocking($client, 1);
// ชื่อไฟล์
$file_name = basename($file_to_transfer);
// ข้อมูลไฟล์ไบนารี
$file_data = file_get_contents($file_to_transfer);
// ความยาวของส่วนหัวโปรโตคอล 4 ไบต์ + 1 ไบต์ เป็นความยาวชื่อไฟล์
$PACKAGE_HEAD_LEN = 5;
// แพ็กเกจโปรโตคอล
$package = pack('NC', $PACKAGE_HEAD_LEN + strlen($file_name) + strlen($file_data), $name_len) . $file_name . $file_data;
// ดำเนินการอัปโหลด
fwrite($client, $package);
// แสดงผลลัพธ์
echo fread($client, 8192),"\n";

ตัวอย่างการใช้งานไคลเอนต์

รันใน command line php client.php <เส้นทางไฟล์>

เช่น php client.php abc.jpg

ตัวอย่างที่สี่ (ใช้โปรโตคอลข้อความในการอัปโหลดไฟล์)

การกำหนดโปรโตคอล

json + การเปลี่ยนบรรทัด json ที่มีชื่อไฟล์และข้อมูลไฟล์ที่เข้ารหัสด้วย base64_encode (จะเพิ่มขึ้น 1/3 ของขนาด)

ตัวอย่างโปรโตคอล

{"file_name":"logo.png","file_data":"PD9waHAKLyo......"}\n

โปรดทราบว่ามีการใช้ตัวอักษรการเปลี่ยนบรรทัดที่ด้านท้าย ใน PHP ใช้สัญลักษณ์อัญประกาศคู่ "\n" ระบุ

การใช้งานโปรโตคอล

namespace Protocols;
class TextTransfer
{
    public static function input($recv_buffer)
    {
        $recv_len = strlen($recv_buffer);
        if($recv_buffer[$recv_len-1] !== "\n")
        {
            return 0;
        }
        return strlen($recv_buffer);
    }

    public static function decode($recv_buffer)
    {
        // แพ็กข้อมูล
        $package_data = json_decode(trim($recv_buffer), true);
        // ดึงชื่อไฟล์
        $file_name = $package_data['file_name'];
        // ดึงข้อมูลไฟล์ที่เข้ารหัส base64_encode
        $file_data = $package_data['file_data'];
        // base64_decode คืนค่ากลับเป็นข้อมูลไฟล์ไบนารีเดิม
        $file_data = base64_decode($file_data);
        // ส่งกลับข้อมูล
        return array(
             'file_name' => $file_name,
             'file_data' => $file_data,
         );
    }

    public static function encode($data)
    {
        // สามารถแก้ไขตามต้องการเพื่อเข้ารหัสข้อมูลที่ส่งให้กับคลายเอนต์ ในที่นี้เพียงส่งกลับข้อมูลตามต้นฉบับ
        return $data;
    }
}

ตัวอย่างการใช้งานโปรโตคอลบนเซิร์ฟเวอร์

หมายเหตุ: รูปแบบการเขียนคล้ายกับการอัปโหลดแบบไบนารี หมายความว่าสามารถสลับโปรโตคอลได้โดยไม่ต้องเปลี่ยนแปลงโค้ดธุรกิจใดๆ เกือบทั้งหมด

use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('TextTransfer://0.0.0.0:8333');
// บันทึกไฟล์เป็น tmp
$worker->onMessage = function(TcpConnection $connection, $data)
{
    $save_path = '/tmp/'.$data['file_name'];
    file_put_contents($save_path, $data['file_data']);
    $connection->send("upload success. save path $save_path");
};

Worker::runAll();

ไคลเอนต์ไฟล์ textclient.php (ใช้ php จำลองการอัปโหลดของไคลเอนต์)

<?php
/** ไคลเอนต์อัปโหลดไฟล์ **/
// ที่อยู่ในการอัปโหลด
$address = "127.0.0.1:8333";
// ตรวจสอบพารามิเตอร์เส้นทางไฟล์อัปโหลด
if(!isset($argv[1]))
{
   exit("ใช้ php client.php \$file_path\n");
}
// เส้นทางไฟล์ที่อัปโหลด
$file_to_transfer = trim($argv[1]);
// ไม่พบไฟล์ในระบบ
if(!is_file($file_to_transfer))
{
    exit("$file_to_transfer not exist\n");
}
// สร้างการเชื่อมต่อ socket
$client = stream_socket_client($address, $errno, $errmsg);
if(!$client)
{
    exit("$errmsg\n");
}
stream_set_blocking($client, 1);
// ชื่อไฟล์
$file_name = basename($file_to_transfer);
// ข้อมูลไฟล์ไบนารี
$file_data = file_get_contents($file_to_transfer);
// encoding base64
$file_data = base64_encode($file_data);
// แพ็กเกจข้อมูล
$package_data = array(
    'file_name' => $file_name,
    'file_data' => $file_data,
);
// แพ็กเกจโปรโตคอล json + การเปลี่ยนบรรทัด
$package = json_encode($package_data)."\n";
// ดำเนินการอัปโหลด
fwrite($client, $package);
// แสดงผลลัพธ์
echo fread($client, 8192),"\n";

ตัวอย่างการใช้งานไคลเอนต์

รันใน command line php textclient.php <เส้นทางไฟล์>

เช่น php textclient.php abc.jpg