Swoole和Workerman是两个基于PHP语言的高性能网络通信框架，它们在实现并发数据传输的能力方面都有很高的表现。特别是在消息队列的应用场景下，它们都能够快速、高效地处理大量的数据传输任务。本文将通过具体的代码示例，来展示它们在PHP与MySQL中的并发数据传输能力。

首先，我们先来介绍一下Swoole和Workerman的特点和优势。Swoole是一个基于PHP扩展的高性能网络通信框架，它可以轻松实现异步、并发和高并发的网络通信。Workerman也是一个高性能的PHP网络通信框架，它采用多进程模型来处理连接，可以同时处理大量的并发连接。

在PHP与MySQL的并发数据传输中，消息队列常常被用作中间件，用于解耦数据传输的发送方和接收方。下面将分别展示Swoole和Workerman在消息队列的应用中的代码示例。

首先是Swoole的示例代码：

// 创建Swoole的异步客户端
$client = new SwooleAsyncClient(SWOOLE_SOCK_TCP);

// 连接到MySQL服务器
$client->connect('127.0.0.1', 3306, function($client) {
    // 连接成功后发送SQL查询语句
    $client->send("SELECT * FROM table");
});

// 接收到服务器返回的数据
$client->on('receive', function($client, $data) {
    // 处理数据
    echo $data;
});

// 连接失败或关闭连接时处理
$client->on('close', function($client) {
    echo '连接关闭';
});

// 启动事件循环
SwooleEvent::wait();

上面的代码使用Swoole的异步客户端连接MySQL服务器，并发送一个查询语句。在接收到服务器返回的数据后，可以进行相应的处理，比如打印到控制台上。

接下来是Workerman的示例代码：

require_once __DIR__ . '/vendor/autoload.php';

use WorkermanWorker;
use WorkermanMySQLConnection;

// 创建一个Worker，监听端口
$worker = new Worker('tcp://127.0.0.1:8888');

// 设置进程数为4
$worker->count = 4;

// 连接到MySQL数据库
$db = new Connection('127.0.0.1', 3306, 'username', 'password', 'database');

// 处理数据传输任务
$worker->onMessage = function($connection, $data) use ($db) {
    // 执行SQL查询语句
    $result = $db->query("SELECT * FROM table");

    // 处理查询结果
    foreach($result as $row) {
        // 处理每一行数据
        echo $row['field']."
";
    }

    // 发送结果到客户端
    $connection->send(json_encode($result));
};

// 启动Worker
Worker::runAll();

上面的代码使用Workerman创建了一个监听端口为8888的Worker，当接收到数据时，会执行SQL查询语句并处理查询结果。最后通过连接向客户端发送查询结果。

通过以上的示例代码，我们可以看到Swoole和Workerman在PHP与MySQL中的并发数据传输能力。它们都能够快速、高效地处理大量的数据传输任务，通过异步和多进程的设计模式，提供了很好的并发性能和可扩展性。在实际应用中，根据具体的场景需求选择合适的框架可以获得更好的性能和用户体验。