微信搜索superit|邀请体验:大数据, 数据管理、OLAP分析与可视化平台 | 赞助作者:赞助作者

WorkerMan学习篇:连接mysql时到底发生了什么鬼

php aide_941 27℃

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。

本文链接

上节课()我们已经了解了,使用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的牛逼了吧。

转载请注明:SuperIT » WorkerMan学习篇:连接mysql时到底发生了什么鬼

喜欢 (1)or分享 (0)