以下將探討用php擴充套件swoole實現實時非同步任務佇列傳送簡訊的方案。

服務端

第一步：建立tcp伺服器

第二步：設定伺服器的相關屬性

第三步：設定服務端的相關回調函式處理任務

具體程式碼如下：tcp_server.php

<?php
class Server{
  private $serv;
  public function __construct(){

    $this->serv = new swoole_server("0.0.0.0",9501);
    $this->serv->set(
      array(  
            'worker_num' => 1,                //一般設定為伺服器CPU數的1-4倍  
            'daemonize' => 1,                 //以守護程序執行  
            'max_request' => 10000,  
            'dispatch_mode' => 2,  
            'task_worker_num' => 8,           //task程序的數量  
            "task_ipc_mode " => 3,            //使用訊息佇列通訊，並設定為爭搶模式  
            "log_file" => "log/taskqueueu.log",
        )
    );
    $this->serv->on('Receive',array($this,'onReceive'));
    $this->serv->on('Task',array($this,'onTask'));
    $this->serv->on('Finish',array($this,'onFinish'));   
    $this->serv->start();

  }
  public function onReceive(swoole_server $serv, $fd, $from_id, $data){
    $serv->task($data);
  }
  public function onTask($serv, $task_id, $from_id, $data){
    $data = json_decode($data,true);
    if(!empty($data)){
      return $this->sendsms($data['mobile'],$data['message']);   
    }
  }
  public function onFinish($serv, $task_id, $data){
      echo "Task {$task_id} finish\n";
  }
  public function sendsms($mobile,$text)
	{
		$timestamp = date("Y-m-d H-i-s");
		$pid = "888888888";
		$send_sign = md5($pid.$timestamp."abcdefghijklmnopqrstuvwxyz");
		$post_data = array();  
		$post_data['partner_id'] = $pid;  
		$post_data['timestamp'] =$timestamp;  
		$post_data['mobile'] = $mobile;  
		$post_data['message'] = $text;  
		$post_data['sign'] = $send_sign;  
		$url='http://182.92.149.100/sendsms';  
		$o="";  
		foreach ($post_data as $k=>$v)  
		{  
			$o.= "$k=".urlencode($v)."&";  
		}  
		$post_data=substr($o,0,-1);  
		$ch = curl_init();  
		curl_setopt($ch, CURLOPT_POST, 1);  
		curl_setopt($ch, CURLOPT_HEADER, 0);  
		curl_setopt($ch, CURLOPT_URL,$url);  

		//為了支援cookie  
		//curl_setopt($ch, CURLOPT_COOKIEJAR, 'cookie.txt');  
		curl_setopt($ch, CURLOPT_POSTFIELDS, $post_data);  
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
		$result = curl_exec($ch);  
		if(strpos($result,"success")!==false)
		{
			$outstr=1;
		}
		else
		{
			$outstr=502;
		}
		return $outstr;
	
	}
}
$server = new Server();
?>
 

客戶端

啟動後端服務後，客戶端首先建立tcp客戶端伺服器，然後連線tcp後端伺服器，並向後端tcp伺服器傳送資料，具體程式碼如下：client.php

<?php
class Client{
  public $client;
  public function __construct(){
    $this->client= new swoole_client(SWOOLE_SOCK_TCP);//默認同步tcp客戶端，新增引數SWOOLE_SOCK_ASYNC為非同步
  }
  public function connect(){
    if(!$this->client->connect('127.0.0.1',9501,1)){
      throw new Exception(sprintf('Swoole Error: %s', $this->client->errCode));
    }
  }
  public function send($data){
    if($this->client->isConnected()){
      $data = json_encode($data);
      //print $data;  
      if($this->client->send($data)){
         return 1;    
      }else{
        throw new Exception(sprintf('Swoole Error: %s', $this->client->errCode));
      }
    }else{
      throw new Exception('Swoole Server does not connected.');  
    }

  }
  public function close(){
    $this->client->close();
  }
}
$client= new Client();
$client->connect();
$data=array(
  'mobile'=>'18511487955',
  'message'=>'you mobile 18511487955'
);
if($client->send($data)){
  echo 'succ';
}else{
  echo 'fail';
}
?>