diff --git a/src/main/java/com/telpo/iotgateway/IotGatewayApplication.java b/src/main/java/com/telpo/iotgateway/IotGatewayApplication.java index 248d0d3..163ffe0 100644 --- a/src/main/java/com/telpo/iotgateway/IotGatewayApplication.java +++ b/src/main/java/com/telpo/iotgateway/IotGatewayApplication.java @@ -26,11 +26,12 @@ import org.springframework.scheduling.annotation.EnableScheduling; public class IotGatewayApplication { public static void main(String[] args) { + log.info("推送服务开始启动!"); ConfigurableApplicationContext applicationContext = SpringApplication.run(IotGatewayApplication.class, args); ConfigurableEnvironment environment = applicationContext.getEnvironment(); IotCommunication iotCommunication = new IotCommunication(environment); iotCommunication.start(); - log.info("推送服务启动!"); + log.info("推送服务启动成功!"); } } diff --git a/src/main/java/com/telpo/iotgateway/server/IotCommunication.java b/src/main/java/com/telpo/iotgateway/server/IotCommunication.java index 55ee98b..9f4ebcf 100644 --- a/src/main/java/com/telpo/iotgateway/server/IotCommunication.java +++ b/src/main/java/com/telpo/iotgateway/server/IotCommunication.java @@ -118,34 +118,4 @@ public class IotCommunication { log.error("InterruptedException:{}", e.getMessage()); } } - - - /* - * userInfo组装 - */ - private String getUserInfo() { - //userInfo组装 - String userInfo = clientId + "|authMode=aksign" - + ",signMethod=" + signMethod - + ",timestamp=" + timeStamp - + ",authId=" + accessKey - + ",iotInstanceId=" + iotInstanceId - + ",consumerGroupId=" + consumerGroupId - + "|"; - //计算签名,password组装方法,请参见AMQP客户端接入说明文档。 - return userInfo; - } - - /** - * 计算签名,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); - } - - }