rcgjfw/Home/Lib/Class/ClientSend.php

<?php
namespace Jiaruan;

class ClientSend {
			

	private $host ;
	
	private $port ;
	
	private $socket ;
	
	private $error ;
	
	private $result ;
	

 
	public  function __construct( $host, $port ){
		$test = '';
		$this->host = $host;
		$this->port = $port;
	}
	
 
	public  function send( $msg ){
		$this->socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
		if ($this->socket === FALSE) {
			return array('success' => false,
						 'message' => "socket创建失败: " . socket_strerror(socket_last_error()));
		}
		socket_set_option($this->socket, SOL_SOCKET, SO_SNDTIMEO, array('sec' => 3, 'usec' => 0));
		socket_set_option($this->socket, SOL_SOCKET, SO_RCVTIMEO, array('sec' => 3, 'usec' => 0));
		
		if (!$this->conn()) {
			socket_close($this->socket);
			return array('success' => false, 'message' => $this->error);
		}
		
		if (!$this->wri($msg . chr(0), strlen($msg) + 1)) {
			socket_close($this->socket);
			return array('success' => false, 'message' => $this->error);
		}
		if (!$this->red()) {
			socket_close($this->socket);
			return array('success' => false, 'message' => $this->error);
		}
		$ret = json_decode($this->result, true);
		if (is_array($ret))
			return $ret;
		return array('success' => false, 'message' => '返回数据格式错误:' .$this->result);
	}
	
 
	private  function conn(  ){
		$timeout = 5;
		socket_set_nonblock($this->socket);
		$time = time();
		while (!@socket_connect($this->socket, $this->host, $this->port)) {
			$err = socket_last_error($this->socket);
			if($err === 56) {
				//echo 'connected ok';
				break;
			}
			if ((time() - $time) >= $timeout) {
				$this->error = '连接超时';
				return false;
			}
			usleep(250000);
		}
		socket_set_block($this->socket);
		return true;
	}
	
 
	private  function wri( $msg, $length ){
		while(true) {
			$sent = socket_write($this->socket, $msg, $length);
			if($sent === false) {
				$this->error = "发送失败" . socket_strerror(socket_last_error());;
				return false;
			}
			if($sent < $length) {
				$msg = substr($msg, $sent);
				$length -= $sent;
				//echo "这些字节没法送 :$msg:重新发送";
				$this->error = "发送失败,信息发送不完整";
				return false;
			} else {
				return true;
			}
		}
	}
	
 
	private  function red(  ){
		socket_clear_error();
		while (true) {
			$out = socket_read($this->socket, 2048);
		
			if ($out == false)
				break;
			$this->result .= $out;
		}
		$errorCode = socket_last_error($this->socket);
		if ($errorCode == 115 || $errorCode == 114 || $errorCode == 104) {
			//            echo "\n连接关闭\n";
			return true;
		} else if ($errorCode == 11) { //读取超时
			$this->error = "读取超时";
		} else {
			$this->error = "读取失败:" . socket_strerror($errorCode);
		}
		return false;
	}
	

}