PHPackages                             jundayw/socket - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Utility & Helpers](/categories/utility)
4. /
5. jundayw/socket

ActiveLibrary[Utility & Helpers](/categories/utility)

jundayw/socket
==============

Simple PHP native Socket

v0.7.4(2y ago)0871MITPHPPHP >=8.1.0

Since May 15Pushed 2y ago1 watchersCompare

[ Source](https://github.com/jundayw/socket)[ Packagist](https://packagist.org/packages/jundayw/socket)[ RSS](/packages/jundayw-socket/feed)WikiDiscussions master Synced 1mo ago

READMEChangelogDependenciesVersions (6)Used By (1)

这是一个演示如何使用 `PHP` 的原生 `Socket` 扩展进行网络编程的示例。该示例包含了建立连接、发送和接收数据的基本操作。

环境要求
====

[](#环境要求)

- `PHP` 8.1 或更高版本
- 安装了 `Socket` 扩展（通常在 PHP 默认安装中包含）

使用方法
====

[](#使用方法)

- 命令行下, 执行 `composer` 命令安装:

```
composer require jundayw/socket
```

- 打开 `Server.php` 文件，修改以下代码中的 IP 地址和端口号：

```
use Jundayw\Socket\SocketServer;

$server = new SocketServer('0.0.0.0', 8808);
//$server->setDomain(AF_INET);
//$server->setType(SOCK_STREAM);
//$server->setProtocol(SOL_TCP);
//$server->setOptions([
//    [SOL_SOCKET, SO_REUSEADDR, 1]
//]);
//$server->setAddress('0.0.0.0');
//$server->setPort(8808);
//$server->setLength(1024);
//$server->setFlags(MSG_WAITALL);

$server->encode = function ($buffer) {
    $buffer = mb_convert_encoding($buffer, 'GBK', 'utf8');
    return pack('a*', $buffer);
};

$server->decode = function ($buffer) {
    $buffer = unpack('a*', $buffer)[1];
    return mb_convert_encoding($buffer, 'utf8', 'GBK');
};

$server->onConnect = function ($socket) use ($server){
    $this->bind($socket, $uid = mt_rand(10000, 99999));
    $this->echo('Client connected', [$uid]);
};

$server->onMessage = function ($socket) use ($server){
    $message = $this->read($socket);
    $this->echo('Received message from', [$uid = $this->getClientUID($socket)], $message);
    // // 广播消息给所有客户端
    // foreach ($this->getClients() as $client) {
    //     if ($client == $this->getMaster()) {
    //         continue;
    //     }
    //     $this->write($client, $message);
    // }
    // // 给指定用户发消息
    // foreach ($this->getConnections() as $connection) {
    //     if ($connection->getUID() == $uid) {
    //         $this->write($connection->socket(), $message);
    //     }
    // }
    // 给当前用户发消息
    $this->write($socket, $message);
};

$server->onDisconnect = function ($socket) use ($server){
    $this->echo('Client disconnected', [$this->getClientUID($socket)]);
    $this->removeBind($socket);
};

try {
    $server->run();
} catch (Exception $exception) {
    echo $exception->getMessage();
}
```

- 打开 `Client.php` 文件，修改以下代码中的 IP 地址和端口号：

```
use Jundayw\Socket\SocketClient;

$client = new SocketClient('127.0.0.1', 8808);
//$client->setDomain(AF_INET);
//$client->setType(SOCK_STREAM);
//$client->setProtocol(SOL_TCP);
//$client->setOptions([
//    [SOL_SOCKET, SO_REUSEADDR, 1]
//]);
//$client->setAddress('0.0.0.0');
//$client->setPort(8808);
//$client->setLength(1024);
//$client->setFlags(MSG_WAITALL);

$client->encode = function ($buffer) {
    $buffer = mb_convert_encoding($buffer, 'GBK', 'utf8');
    return pack('a*', $buffer);
};

$client->decode = function ($buffer) {
    $buffer = unpack('a*', $buffer)[1];
    return mb_convert_encoding($buffer, 'utf8', 'GBK');
};

$client->onConnect = function ($socket) use ($client){
    echo "Connected to server 127.0.0.1:8808 ...\n";
};

$client->onMessage = function ($socket) use ($client){
    while (true) {
        echo 'input: ' . PHP_EOL;
        $message = fgets(STDIN);
        $message = str_replace(PHP_EOL, '', $message);

        if (empty($message)) {
            continue;
        }

        if ($message == 'q') {
            break;
        }

        echo 'input message: ' . $message . PHP_EOL;
        // 发送消息
        $this->write($socket, $message);
        // 接收服务器应答消息
        if (is_null($buffer = $this->read($socket))) {
            echo 'socket_read() failed: ' . socket_strerror(socket_last_error()) . PHP_EOL;
            break;
        }
        // 打印应答消息内容
        echo 'Received reply message: ' . $buffer . PHP_EOL;
    }
};

$client->onDisconnect = function ($socket) use ($client){
    echo "disconnected to server 127.0.0.1:8808 ...\n";
};

try {
    $client->run();
} catch (Exception $exception) {
    echo $exception->getMessage();
}
```

- 启动服务器：

```
php Server.php
```

- 运行客户端：

```
php Client.php
```

- 在客户端终端中，你将看到成功建立连接并发送接收数据的输出。

注意事项
====

[](#注意事项)

- 本示例仅用于演示目的，请不要在生产环境中直接使用。在实际开发中，需要考虑异常处理、错误处理和安全性等方面的更多问题。
- 如需了解更多关于 PHP Socket 扩展的详细信息，请参考 PHP 官方文档：[PHP: Sockets - Manual](https://www.php.net/manual/en/book.sockets.php)

###  Health Score

23

—

LowBetter than 27% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity9

Limited adoption so far

Community9

Small or concentrated contributor base

Maturity47

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 100% of commits — single point of failure

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

###  Release Activity

Cadence

Every ~48 days

Total

5

Last Release

906d ago

### Community

Maintainers

![](https://www.gravatar.com/avatar/2da9b458375a1b7972b7c4d26a5bf8f3e48db305e8805da36f253956f33c5568?d=identicon)[jundayw](/maintainers/jundayw)

---

Top Contributors

[![jundayw](https://avatars.githubusercontent.com/u/16873970?v=4)](https://github.com/jundayw "jundayw (8 commits)")

### Embed Badge

![Health badge](/badges/jundayw-socket/health.svg)

```
[![Health](https://phpackages.com/badges/jundayw-socket/health.svg)](https://phpackages.com/packages/jundayw-socket)
```

###  Alternatives

[fetchleo/laravel-xml

Convert Eloquent models to XML, as well as normal objects.

104.2k](/packages/fetchleo-laravel-xml)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)