基于泛化协议SDK的TCP Server开发接口，您可以快速构建以TCP为传输协议的接入服务，并将其与阿里云物联网平台桥接。

启动引导

com.aliyun.iot.as.bridge.server.BridgeServerBootstrap是启动Socket服务器和桥接服务的引导类。创建新的BridgeServerBootstrap实例后，会初始化基于配置文件的自定义配置管理组件。

示例代码：

BridgeServerBootstrap bootstrap = new BridgeServerBootstrap(new TcpDecoderFactory() {
    @Override
    public ByteToMessageDecoder newInstance() {
        // 返回解码器
    }
}, new TcpEncoderFactory() {
    @Override
    public MessageToByteEncoder<?> newInstance() {
        // 返回编码器
    }
}, new TcpBasedProtocolAdaptorHandlerFactory() {
    @Override
    public CustomizedTcpBasedProtocolHandler newInstance() {
        // 返回协议适配器
    }
}, new DefaultDownlinkChannelHandler());
try {
    bootstrap.start();
} catch (BootException | ConfigException e) {
    // 处理启动失败
}

实例化TCP类型BridgeServerBootstrap

  • com.aliyun.iot.as.bridge.server.channel.factory.TcpDecoderFactory: 协议解码器工厂类具体实现，负责如何创建一个新的解码器实例，用于上行数据的解析，线程安全，可为null。
  • com.aliyun.iot.as.bridge.server.channel.factory.TcpEncoderFactory: 协议编码器工厂类具体实现，负责如何创建一个新的编码器实例，用于下行数据到协议编码的转换，线程安全，可为null。
  • com.aliyun.iot.as.bridge.server.channel.factory.TcpBasedProtocolAdaptorHandlerFactory: 协议适配器工厂类具体实现，负责如何创建一个新的协议适配器实例，用于解码器解析出来的数据到云端数据的转换，线程安全，不可为null。
  • com.aliyun.iot.as.bridge.core.handler.DownlinkChannelHandler: 云端下行数据分发处理器，支持单播和广播。单播默认直接转发云端下发的数据到设备，广播需开发者自定义具体实现。可为null，为null时表示不支持下行。

启动Socket Server

创建BridgeServerBootstrap完成后，需调用com.aliyun.iot.as.bridge.server.BridgeServerBootstrap.start()完成Socket Server启动。

协议解码

协议解码组件需派生自io.netty.handler.codec.ByteToMessageDecoder，具体内容请参考ByteToMessageDecoder文档。

示例代码：

public class SampleDecoder extends ByteToMessageDecoder {
    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
        // 解码协议
    }
}

协议编码

协议编码组件需派生自io.netty.handler.codec.MessageToByteEncoder<I>，具体内容请参考MessageToByteEncoder文档。

示例代码：

public class SampleEncoder extends MessageToByteEncoder<String>{
    @Override
    protected void encode(ChannelHandlerContext ctx, String msg, ByteBuf out) throws Exception {
        // 协议编码
    }
}

协议适配器

为了降低开发成本，提高泛化协议设备接入与桥接服务的开发效率，泛化协议Server SDK为协议适配器提供了可扩展、可定制的基础能力类com.aliyun.iot.as.bridge.server.channel.CustomizedTcpBasedProtocolHandler。其封装了与阿里云物联网平台的对接细节，使您可以专注于协议本身的业务，无需关注具体的对接细节。泛化协议的协议处理适配器需派生自该类。

设备上线

当设备建立连接或者发送连接请求时，应触发设备上线操作。设备上线分为两个部分：网桥本地Session的初始化以及设备认证。

  1. Session初始化

    具体内容请参见核心SDK>设备上线>Session初始化。

  2. 设备认证

    本地Session初始化完成后即可调用doOnline(ChannelHandlerContext ctx, Session newSession, String originalIdentity, String... credentials)完成本地设备认证和阿里云物联网平台上线认证。认证成功，设备可以进行通信；认证失败，设备将断开连接。

    示例代码：

    Session session = Session.newInstance(device, channel);
boolean success = doOnline(session, originalIdentity);
if (success) {
    // 上线成功，接受后续通信请求
} else {
    // 上线失败，拒绝后续通信请求，断开连接（如有）
}

设备下线

当设备连接断开或者网桥探测到需要断开连接时，应触发设备下线操作。Server SDK自身提供了设备连接断开时自动下线设备的能力，开发者只需负责处理主动触发设备下线操作的情形即可，下线某个设备可通过接口doOffline(Session session)实现。

上报数据

协议适配器需override channelRead(ChannelHandlerContext ctx, Object msg)方法，该方法是所有设备上行数据的入口，msg为decoder所返回的数据。

上报数据到物联网平台包括三步：获取上行数据关联的设备、找到设备关联的Session、上报数据到物联网平台。需通过以下接口完成数据上报：

  • CompletableFuture doPublishAsync(Session session, String topic, byte[] payload, int qos)：异步发送数据并立即返回，开发者需根据future判断发送结果。
  • CompletableFuture doPublishAsync(Session session, ProtocolMessage protocolMsg)：异步发送数据并立即返回，开发者需根据future判断发送结果。
  • boolean doPublish(Session session, ProtocolMessage protocolMsg, int timeout)：异步发送数据并等待发送结果返回。
  • boolean doPublish(Session session, String topic, byte[] payload, int qos, int timeout)：异步发送数据并等待发送结果返回。
示例代码：
DeviceIdentity identity = ConfigFactory.getDeviceConfigManager().getDeviviceIdentity(device);
if (identity == null) {
    // 设备未成功映射到阿里云物联网平台上的设备，丢弃消息
    return;
}
Session session = SessionManagerFactory.getInstance().getSession(device);
if (session == null) {
    // 设备尚未上线，请上线设备或者丢弃消息。上报数据到物联网平台前请务必确保设备已上线。
}
boolean success = doPublish(session, topic, payload, 0, 10);
if(success) {
    // 成功上报数据到阿里云物联网平台
} else {
    // 上报数据到阿里云物联网平台失败
}

下行消息

具体请参考核心SDK>下行消息文档。

SDK提供了com.aliyun.iot.as.bridge.core.handler.DefaultDownlinkChannelHandler作为下行数据的分发处理器。支持单播和广播，其中单播默认直接转发云端下发的数据到设备，广播需开发者自定义具体实现。开发者可以通过派生子类实现行为定制。

示例代码：
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
...

public class SampleDownlinkChannelHandler implements DownlinkChannelHandler {
    @Override
    public boolean pushToDevice(Session session, String topic, byte[] payload) {
        // 从设备对应的session中取出通信通道
        Channel channel = (Channel) session.getChannel().get();
        if (channel != null && channel.isWritable()) {
            String body = new String(payload, StandardCharsets.UTF_8);
            // 发送下行数据到设备
            ChannelFuture future = channel.pipeline().writeAndFlush(body);
            future.addListener(ChannelFutureListener.FIRE_EXCEPTION_ON_FAILURE);
            return true;
        }
        return false;
    }

    @Override
    public boolean broadcast(String topic, byte[] payload) {
        throw new RuntimeException("not implemented");
    }
}