发表新帖

TCP分包设置疑问

java那边定的包协议
```java
/**
     * 包头包体总长
     */
    private Integer length;
    /**
     * 协议命令号
     */
    private Integer cmd;
    /**
     *  消息序列
     */
    private Integer seq;

/**
     * 请求结果
     */
    private byte type;
    /**
     * 用户账户
     */
    private Long uid;

/**
     * 包体文件
     */
    private byte[] protoBuf;
```
我用swoole进行模拟测试。
server.php
```php
<?php

//创建Server对象，监听 127.0.0.1:9501端口
$serv = new Swoole\Server("127.0.0.1", 9501);

$serv->set(array(
    'open_length_check' => true,
    'package_length_type' => 'N',
    'package_body_offset' => 0,
    'package_length_offset' => 0,
    'package_max_length' => 81920,
));

//监听连接进入事件
$serv->on('Connect', function ($serv, $fd) {
    echo "Client: Connect.\n";
});

//监听数据接收事件
$serv->on('Receive', function ($serv, $fd, $from_id, $data) {
    $arr = unpack('Nlength/Ncmd/Nseq/ctype/quid/a*protoBuf', $data);
    $serv->send($fd, var_export($arr, true));
});

//监听连接关闭事件
$serv->on('Close', function ($serv, $fd) {
    echo "Client: Close.\n";
});

//启动服务器
$serv->start();
```
client.php
```php
<?php

$client = new \Swoole\Client(SWOOLE_SOCK_TCP);

if (!$client->connect('127.0.0.1', 9501, -1)) {
    exit("connect failed. Error: {$client->errCode}\n");
}

$cmd = pack('N', 100);
$seq = pack('N', 1000);
$type = pack('c', 1);
$uid = pack('q', 10000);
$protoBuf = pack('a*', 'abc');
$tmp = $cmd.$seq.$type.$uid.$protoBuf;
$length = pack('N', 32 + strlen($tmp));
$send = $length.$tmp;

$client->send($send);

echo $client->recv(), PHP_EOL;

$client->close();
```
当我把`open_length_check`设置为`false`的时候，上面的代码是能跑通的，由于我对于`pack()`与`unpack()`我一直看不懂，所以我不知道是我的`pack()`与`unpack()`不行，还是`swoole`的分包没设置对，或是都有问题，请大佬教学一波，感谢。

发布于6年前 · 13 次浏览 · 来自讨论

天王盖地虎

/**
     * 请求结果
     */
    private byte type;
    /**
     * 用户账户
     */
    private Long uid;

/**
     * 包体文件
     */
    private byte[] protoBuf;
```
我用swoole进行模拟测试。
server.php
```php
<?php

//创建Server对象，监听 127.0.0.1:9501端口
$serv = new Swoole\Server("127.0.0.1", 9501);

$serv->set(array(
    'open_length_check' => true,
    'package_length_type' => 'N',
    'package_body_offset' => 0,
    'package_length_offset' => 0,
    'package_max_length' => 81920,
));

//监听连接进入事件
$serv->on('Connect', function ($serv, $fd) {
    echo "Client: Connect.\n";
});

//监听连接关闭事件
$serv->on('Close', function ($serv, $fd) {
    echo "Client: Close.\n";
});

//启动服务器
$serv->start();
```
client.php
```php
<?php

$client = new \Swoole\Client(SWOOLE_SOCK_TCP);

if (!$client->connect('127.0.0.1', 9501, -1)) {
    exit("connect failed. Error: {$client->errCode}\n");
}

$client->send($send);

echo $client->recv(), PHP_EOL;

登录后参与评论

2020-04-26

鲁飞

2020-04-26

天王盖地虎 回复鲁飞

2020-04-26

天王盖地虎 回复鲁飞