开始连接，这一步如果失败会一直重连，周期为30秒(30秒的意思不是说30秒重连一次，而是30秒内都在重连，30秒内没连接上会重新订阅重新连接，等于一直在重连) @param host @param port @return

发送数据，超过五秒发送失败(指定在io线程发送数据) @param data @return

心跳频率 @param period @return

线程切换 @param <T> @return

读取数据 @param <T> @return

心跳、重连机制的订阅(心跳数据初始化后不再变化，适用于心跳包数据不改变的情况) @param host @param port @param period 心跳频率 @param data 心跳数据 @return

读取线程开启 @param emitter

关闭socket @throws IOException

心跳 @param period 心跳频率 @param data 心跳数据 @return

心跳包数据动态改变后记得调用该变换方式 @return

重连机制的订阅 @param host @param port @return