上节课()我们已经了解了，使用workerman创建一个HTTP协议的web服务。

问题：我们使用php或java来连接数据库的时候，是不是也是通过类似的原理来连接的呢？

连接mysql有很多种协议，如果是远程连接是通过tcp，如果是本机一般是socket。

1.回顾

<?php

//本机IP是10.211.55.13
//需要监听的端口是 9090


use Workerman\Worker;

require 'workerman/Autoloader.php';

// 创建一个Worker监听9090端口，不使用任何应用层协议
$tcp_worker = new Worker("tcp://10.211.55.13:9090");

// 启动4个进程对外提供服务
$tcp_worker->count = 4;

//当连接建立时触发的回调函数
$tcp_worker->onConnect = function($connection)
{
    echo "new connection from ip " . $connection->getRemoteIp() . "\n";
};

// 当客户端发来数据时
$tcp_worker->onMessage = function($connection, $data)
{
    // 向客户端发送hello $data
    $connection->send('hello ' . $data);
    $connection->close();
};

// 运行worker
Worker::runAll();

这是『直接使用TCP传输数据』的形式，注意今天我们的代码中多了一个onConnect，这是当连接建立时触发的回调函数。每个连接只会触发一次onConnect回调。

我们开启服务，然后用浏览器来访问10.211.55.13:9090，看看是否会触发onConnect这个回调函数。

我们在浏览器中建立了2个连接，发现服务端输出了2次new connection from ip 10.211.55.2。

2.和mysql有啥关系？

我们用msyql客户端来尝试连接，发现我们的socket服务端，也会输出new connection from ip 10.211.55.2 这样的字符串，说明也触发了onConnect 这个回调函数。

3.既然我们的mysql客户端能够成功连接我们的socket服务器，那么我们怎么才能连接上mysql呢？
用socket服务端来做中转服务(也就是mysql代理服务)。

server.php:

<?php

//本机IP是10.211.55.13
//需要监听的端口是 9090


use Workerman\Connection\AsyncTcpConnection;
use Workerman\Worker;

require 'workerman/Autoloader.php';

// 创建一个Worker监听9090端口，不使用任何应用层协议
$tcp_worker = new Worker("tcp://10.211.55.13:9090");

// 启动4个进程对外提供服务
$tcp_worker->count = 4;

//当连接建立时触发的回调函数
$tcp_worker->onConnect = function($connection)
{
    echo "new connection from ip " . $connection->getRemoteIp() . "\n";

    // 异步建立一个到实际mysql服务器的连接
    $connection_to_mysql = new AsyncTcpConnection('tcp://127.0.1:3306');
    // 执行异步连接
    $connection_to_mysql->connect();

    // mysql连接发来数据时，转发给对应客户端的连接
    $connection_to_mysql->onMessage = function($connection_to_mysql, $buffer)use($connection)
    {
        $connection->send($buffer); //发送mysql数据
    };

    // 客户端发来数据时，转发给对应的mysql连接
    $connection->onMessage = function($connection, $buffer)use($connection_to_mysql)
    {
        $connection_to_mysql->send($buffer);
    };

};

// 当客户端发来数据时
$tcp_worker->onMessage = function($connection, $data)
{
    // 向客户端发送hello $data
    $connection->send('hello ' . $data);
    $connection->close();
};

// 运行worker
Worker::runAll();

其中mysql代理相关的文档在:http://doc3.workerman.net/worker-development/connect.html

输入mysql帐号密码，成功连接。

到这里，我们已经初步领略了WorkerMan的牛逼了吧。