IMI v0.0.7 用 Controller 开发 WebSocket/TCP/UDP 应用

栏目: Html5 · 发布时间: 6年前

内容简介：现在IMI可以像开发http应用一样，使用控制器-动作，WebSocket/TCP/UDP应用。IMI内置支持连接分组，仅仅需要十行代码，就构建出了一个简单的 WebSocket 聊天室，当然这里代码行数没有算定义类、方法等等的代码。首先定义一个 WebSocket 路由，只有指定uri才可以握手。@WSConfig定义了接收和发送数据的编码解码类。

现在IMI可以像开发http应用一样，使用控制器-动作，WebSocket/TCP/UDP应用。IMI内置支持连接分组，仅仅需要十行代码，就构建出了一个简单的 WebSocket 聊天室，当然这里代码行数没有算定义类、方法等等的代码。

首先定义一个 WebSocket 路由，只有指定uri才可以握手。@WSConfig定义了接收和发送数据的编码解码类。

/**
 * 测试
 * @Controller
 */
class Index extends HttpController
{
	/**
	 * 连接地址：ws://127.0.0.1:8083/
	 * 
	 * @Action
	 * @Route("/")
	 * @WSConfig(parserClass=\Imi\Server\WebSocket\Parser\JsonArrayParser::class)
	 * @return void
	 */
	public function index()
	{
		// 握手处理，什么都不做，框架会帮你做好
	}
	
}

真正的业务代码如下，根据@WSRoute配置的路由，如传过来是{"action":"login"}数据则进入login方法处理。下面的代码，还实现了连接分组及分组发送。

/**
 * 数据收发测试
 * @WSController
 */
class Test extends WebSocketController
{
	/**
	 * 登录
	 * 
	 * @WSAction
	 * @WSRoute({"action"="login"})
	 * @return void
	 */
	public function login($data)
	{
		ConnectContext::set('username', $data->username);
		$this->server->joinGroup('g1', $this->frame->getFd());
		return ['success'=>true];
	}

	/**
	 * 发送消息
	 *
	 * @WSAction
	 * @WSRoute({"action"="send"})
	 * @param 
	 * @return void
	 */
	public function send($data)
	{
		$message = ConnectContext::get('username') . ':' . $data->message;
		$this->server->groupCall('g1', 'push', $message);
	}

}

由于这仅仅是一个演示 WebSocket 的 Demo，所以很多细节并没有考虑完善，但是依然掩盖不住 imi 的简单高效！

上面的代码在imi-demo项目中有完整的可以跑，当然你也可以直接进我搭建在双核+4G的老爷机上的演示。用了ngrok，服务器在美国，经不住攻击，大家正常玩就行~发现问题请及时告知我，非常感谢！

演示地址： http://chat-demo.imiphp.com:8084/

tcp聊天室demo及客户端代码，请查看imi-demo项目