唐山道闸18633325372阿里云版，唐山人脸识别系统代码来围观哦

1

IoT助力智能化体温采集

技术架构方案

云端开发

进入物联网平台控制台，创建产品。

在产品详情Topic列表，增加用于数据传输的Topic，如下：

3.2 注册设备

产品定义好后，我们基于这个产品创建一个具体设备，获取到设备身份三元组。

3.3 创建消费组

接下来，我们要在服务端订阅创建用来接收数据的消费组，唐山道闸参看下图：

3.4 配置数据流转的规则

最后，我们通过规则引，把设备上报的数据做业务处理后，流转到我们服务器的消费组，唐山道闸从而实现企业自己的设备采集的业务数据到达企业自己的后台服务器的流转过程。

设备开发

完整代码如下：

// 引入依赖mqtt库，或自己实现 const mqtt = require('aliyun-iot-mqtt'); // 设备身份 var options = { productKey: "设备pk", deviceName: "设备dn", deviceSecret: "设备ds", regionId: "cn-shanghai" }; // 1.建立连接 const client = mqtt.getAliyunIotMqttClient(options); // 2.设备接收云端指令数据 client.on('message', function(topic, message) { console.log("topic " + topic) console.log("message " + message)
}) // 3. 模拟设备 上报数据（原始报文） setInterval(function() {
    client.publish(`/${options.productKey}/${options.deviceName}/user/data`, getPostData(),{qos:1});

}, 1000); // 模拟 设备原有报文格式 function getPostData() { let payload = { temperature:Math.floor((Math.random() * 20) + 10)
    }; console.log("payload=[ " + payload+" ]") return JSON.stringify(payload);
}

服务端开发

参考服务端订阅AMQP文档

https://help.aliyun.com/document_detail/143601.html

核心代码如下：

public class AMQPClient { private final static Logger logger = LoggerFactory.getLogger(AMQPClient.class); //消费组配置参数 private static String accessKey = "阿里云账号ak"; private static String accessSecret = "阿里云账号as"; private static String consumerGroupId = "服务端订阅消费组ID"; private static String aliUID = "替换你的阿里云账号UID"; public static void main(String[] args) throws Exception { long timeStamp = System.currentTimeMillis(); //签名方法 String signMethod = "hmacsha1"; //控制台服务端订阅中消费组状态页客户端ID一栏将显示clientId参数。 //建议使用机器UUID、MAC地址、IP等唯一标识等作为clientId。便于您区分识别不同的客户端。 String clientId = "ecs_"+System.currentTimeMillis(); //UserName组装 String userName = clientId + "|authMode=aksign" + ",signMethod=" + signMethod
                + ",timestamp=" + timeStamp
                + ",authId=" + accessKey
                + ",consumerGroupId=" + consumerGroupId
                + "|"; //password组装 String signContent = "authId=" + accessKey + "×tamp=" + timeStamp;
        String password = doSign(signContent,accessSecret, signMethod); //按照qpid-jms的规范，组装连接URL。 String connectionUrl = "failover:(amqps://"+aliUID+".iot-amqp.cn-shanghai.aliyuncs.com:5671?amqp.idleTimeout=80000)" + "?failover.reconnectDelay=30";

        Hashtable hashtable = new Hashtable<>();
        hashtable.put("connectionfactory.SBCF",connectionUrl);
        hashtable.put("queue.QUEUE", "default");
        hashtable.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.qpid.jms.jndi.JmsInitialContextFactory");
        Context context = new InitialContext(hashtable);
        ConnectionFactory cf = (ConnectionFactory)context.lookup("SBCF");
        Destination queue = (Destination)context.lookup("QUEUE"); // 创建和IoT平台的AMQP连接 Connection connection = cf.createConnection(userName, password);
        ((JmsConnection) connection).addConnectionListener(myJmsConnectionListener); // 创建 Session // Session.CLIENT_ACKNOWLEDGE: 收到消息后，需要手动调用message.acknowledge() // Session.AUTO_ACKNOWLEDGE: SDK自动ACK（推荐） Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        connection.start(); // 创建消费者 MessageConsumer consumer = session.createConsumer(queue);
        consumer.setMessageListener(messageListener);
    } private static MessageListener messageListener = new MessageListener() { @Override public void onMessage(Message message) { try { byte[] body = message.getBody(byte[].class);
                String content = new String(body);
                String topic = message.getStringProperty("topic");
                String messageId = message.getStringProperty("messageId");
                logger.info("receive message" + ", topic = " + topic
                        + ", messageId = " + messageId
                        + ", content = " + content);
                System.out.println(); //如果创建Session选择的是Session.CLIENT_ACKNOWLEDGE，这里需要手动ACK。 //message.acknowledge(); //如果要对收到的消息做耗时的处理，请异步处理，确保这里不要有耗时逻辑。 } catch (Exception e) {
                e.printStackTrace();
            }
        }
    };  private static MessageListener messageListener = new MessageListener() {  //回调  }; /**
     * password签名计算方法，请参见上一篇文档：AMQP客户端接入说明。
     */ private static String doSign(String toSignString, String secret, String signMethod) throws Exception {
        SecretKeySpec signingKey = new SecretKeySpec(secret.getBytes(), signMethod);
        Mac mac = Mac.getInstance(signMethod);
        mac.init(signingKey); byte[] rawHmac = mac.doFinal(toSignString.getBytes()); return Base64.encodeBase64String(rawHmac);
    }
}

设备运行日志

6.1 数据上报日志

6.2 数据流转日志

6.3 服务端订阅消费组情况

唐山千瞳智能成立于2009年，服务热线：18633325372  13153812666 专业唐山车牌识别系统、唐山道闸、唐山楼宇对讲、唐山道闸车牌识别系统、唐山防伪车牌识别系统、唐山液压升降柱、唐山小区智能门禁系统、唐山工地门禁系统、唐山岗亭、唐山广告自动门、唐山人脸识别门禁系统、唐山景区票务系统、唐山地下停车场设施制造商。www.qtzn.vip