swoole-异步mysql

- 日理万妓 2023-06-21 05:56 70阅读 0赞

前言：需要的注意的是，如果swoole版本在4.3以上，我们就不能够使用Async文档中的异步协程回调了！

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA_size_16_color_FFFFFF_t_70]

而替代上方的Async文档的Coroutine文档，我们打开官网的Coroutine的选项，进入到异步mysql的相关文档中  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA_size_16_color_FFFFFF_t_70 1]

1.这里也有一个坑，可能是文档没有描述清楚，我们如果按照上面的下面的这个demo是无法使用的，会报错  
![在这里插入图片描述][20191211205739348.png]  
笔者在这里折腾了一个多小时，终于找到了方法，需要在协程方法中实现该方法，我们上代码

co::create(function() { 
      $swoole_mysql = new Swoole\Coroutine\MySQL();
      $swoole_mysql->connect([ 'host' => 'XXXXX', 'port' => 3306, 'user' => 'root', 'password' => 'XXXX', 'database' => 'swoole', ]); 
      $res = $swoole_mysql->query('select sleep(1)');
       var_dump($res);
    
    });

使用以上方法，则能够正常运行

1.  我们稍微将代码改进成面向对象的方式

<?php 
    
    
    //异步连接mysql
    
    /** * */
    class connect 
    { 	
    	protected  $config =[ 'host' => '127.0.0.1','port' => 3306,'user' => 'swoole','password' => 'woshichaoren1319','database' => 'swoole'];
    	protected  $source ='';
    
    	/** * 初始化对象 */
    	function __construct()
    	{ 	
    		 $this->source = new Swoole\Coroutine\MySQL();
    	}
    
    	/** * 新增操作 */
    	public function add(){ 
    		 co::create(function(){ 
    		 	$this->source->connect($this->config);
    		 	if ($this->source->connected) { 
    		 		echo "连接成功\n";
    		 	}else{ 
    		 		echo "连接失败\n";
    		 	}
    
    			$res= $this->source->query('insert into duo_user (username,create_time) values ("duoduo",now())');
    			if ($res) { 
    			 	echo  "新增成功";
    			} 	
    		 });	
    	}
    
    	/** * 更新操作 */
    	public function upd(){ 
    		co::create(function(){ 
    		 	$this->source->connect($this->config);
    		 	if ($this->source->connected) { 
    		 		echo "连接成功\n";
    		 	}else{ 
    		 		echo "连接失败\n";
    		 	}
    			$res= $this->source->query('update duo_user set status = 1 where status = 0');
    			if ($res) { 
    			 	echo  "更新成功";
    			} 	
    		 });
    	}
    
    	public function del(){ 
    		co::create(function(){ 
    		 	$this->source->connect($this->config);
    		 	if ($this->source->connected) { 
    		 		echo "连接成功\n";
    		 	}else{ 
    		 		echo "连接失败\n";
    		 	}
    			$res= $this->source->query('delete from duo_user where id < 5');
    			if ($res) { 
    			 	echo  "删除成功";
    			} 	
    		 });
    	}
    
    	public function find(){ 
    		co::create(function(){ 
    		 	$this->source->connect($this->config);
    		 	if ($this->source->connected) { 
    		 		echo "连接成功\n";
    		 	}else{ 
    		 		echo "连接失败\n";
    		 	}
    			$res= $this->source->query('select * from duo_user order by id desc limit 1 ');
    			var_dump($res).PHP_EOL;
    			if ($res) { 
    			 	echo  "查询成功";
    			} 	
    		 });
    	}
    }
    
    $res = new connect();
    $res->find();

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191211205527343.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191211205225466.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA==,size_16,color_FFFFFF,t_70
[20191211205739348.png]: https://img-blog.csdnimg.cn/20191211205739348.png