消息服务调整

example/ucenter_message.php

@@ -14,36 +14,17 @@ require __DIR__.'/_init.php';
 Message::setDebug();
 
 //$ret = Message::sendTemplateSmsByUidAsync('12', 'default_code', ['code'=>rand(1000, 9999)]);
-$ret = Message::sendSms('18019580609', 'Hello World 3');
-var_dump($ret);
+//$ret = Message::sendSms('18019580609', 'Hello World 3');
 
 //$ret = Message::sendTemplateSms('18019580609', 'default_code', ['code'=>rand(1000, 9999)]);
-//var_dump($ret);
 
-//$name = uniqid('dev_');
-//$info = \internalApi\ucenter\Message::add(1,0,0,'bbs','system',0,0);
-//print_r($info);
-
-//
-//$info = \internalApi\ucenter\Message::addComment(1,0,0,'bbs','theme',0,0,'','123123');
-//print_r($info);
-
-
-//$info = \internalApi\ucenter\Message::addLike(1,0,0,'bbs','theme',0,0,'');
-//print_r($info);
-
-//$info = \internalApi\ucenter\Message::deleteComment(1,'bbs','theme',0);
-//print_r($info);
-
-//$info = \internalApi\ucenter\Message::deleteLiked(1,'bbs','theme',0);
-//print_r($info);
-
-
-//$info = \internalApi\ucenter\Message::pushMsg(1,0,0,'bbs','theme',0);
-//print_r($info);
+//Message::setUserOnline(12, 60);
+$ret = Message::isUseOnline(12);
 
 //$ret = Message::sendSystemMessageAsync('remind', 0, 12, Message::TYPE_REMIND, [
 //	'title' => '测试的标题',
 //	'text'=>'新消息测试'.uniqid()
 //]);
 //print_r($ret);
+
+var_dump($ret);
\ No newline at end of file

src/base/Client.php

@@ -214,7 +214,11 @@ class Client
 				'host' => $srv['host'],
 				'port' => $srv['port']
 			]);
-			$conn->connect();
+
+			if (!$conn->connect()) {
+				throw new ClientException("Unable to connect to rpc server. {$srv['host']}:{$srv['port']}");
+			}
+
 			$connections[$instance->rpcServer] = $conn;
 		}
 

src/base/HyperfJsonRpc.php

@@ -87,6 +87,7 @@ class HyperfJsonRpc
 		if ($this->connected) {
 			stream_set_timeout($this->_connection, -1);
 		}
+
 		return $this->connected;
 	}
 

src/ucenter/Message.php

@@ -109,6 +109,29 @@ class Message extends Client
 		return self::invoke('/sms/sendTemplateByUidAsync', func_get_args());
 	}
 
+	/**
+	 * 检测指定用户IM是否在线
+	 *
+	 * @param int $uid
+	 * @return bool
+	 */
+	public static function isUseOnline($uid)
+	{
+		return self::invoke('/message/isUserOnline', func_get_args());
+	}
+
+	/**
+	 * 设置用户在线状态
+	 *
+	 * @param int $uid
+	 * @param int|false $status 在线状态，指定保活秒数，或指定 false 代表离线
+	 * @return void
+	 */
+	public static function setUserOnline($uid, $status)
+	{
+		return self::invoke('/message/setUserOnline', func_get_args());
+	}
+
 	/**
 	 * 以系统会话发送消息
 	 *