springboot封装 涂鸦物联网平台API鉴权请求的demo
- 先看依赖
org.springframework.boot spring-boot-starter-data-redis org.apache.httpcomponents httpclient org.apache.httpcomponents httpasyncclient org.bgee.log4jdbc-log4j2 log4jdbc-log4j2-jdbc4.1 1.16 封装的助手类中主要使用httpclient作为请求管理类；并且使用了redis作为缓存提供者，没有用redis的使用其他缓存也可以；
看一下我的redis缓存实现类
package com.abon.smart_family_lot.application.common.util;import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Component;import java.util.concurrent.TimeUnit;/*** desc: redis缓存助手类* author: zmq3821@163.com* date: 2021/12/2 15:09*/ @Component public class RedisCacheUtil {private StringRedisTemplate stringRedisTemplate;@Autowiredpublic void setStringRedisTemplate(StringRedisTemplate stringRedisTemplate) {this.stringRedisTemplate = stringRedisTemplate;}// 设置缓存public void set(String key, String value) {stringRedisTemplate.opsForValue().set(key, value);}// 设置缓存public void set(String key, String value, long expire) {stringRedisTemplate.opsForValue().set(key, value, expire, TimeUnit.SECONDS);}// 获取缓存值public String get(String key) {return stringRedisTemplate.opsForValue().get(key);}// 设置有效期public boolean expire(String key, long expire) {return Boolean.TRUE.equals(stringRedisTemplate.expire(key, expire, TimeUnit.SECONDS));}// 清理缓存public void remove(String key) {if (hasKey(key)) {stringRedisTemplate.delete(key);}}// 缓存递增public Long increment(String key, long delta) {return stringRedisTemplate.opsForValue().increment(key, delta);}// 是否存在指定缓存public boolean hasKey(String key) {return Boolean.TRUE.equals(stringRedisTemplate.hasKey(key));}} -
先看一下我的目录结构，只是为了方便搞清楚代码存放的逻辑。红框里的就是主要使用到文件
- 先在resources创建tuya.yml
#云端 cloud:client-id: xxx #授权密钥client-secret: xxxxxxxxxx #授权密钥endpoint: https://openapi.tuyacn.com #接入地址-中国数据中心 -
在common/config中创建TuyaCloudConfig.java
package com.abon.smart_family_lot.application.common.config;import lombok.Data; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource;@Data @Configuration @PropertySource(value = {"classpath:tuya.yml"}, encoding = "utf-8", factory = YamlConfigFactory.class) @ConfigurationProperties(prefix = "cloud") public class TuyaCloudConfig {private String clientId;private String clientSecret;private String endpoint;}这里用到了 YamlConfigFactory,用于辅助加载yml文件
package com.abon.smart_family_lot.application.common.config;import org.springframework.beans.factory.config.YamlPropertiesFactoryBean; import org.springframework.core.env.PropertiesPropertySource; import org.springframework.core.env.PropertySource; import org.springframework.core.io.support.DefaultPropertySourceFactory; import org.springframework.core.io.support.EncodedResource; import org.springframework.lang.Nullable;import java.io.IOException; import java.util.Properties;public class YamlConfigFactory extends DefaultPropertySourceFactory {@Overridepublic PropertySource createPropertySource(@Nullable String name, EncodedResource resource) throws IOException {String sourceName = name != null ? name : resource.getResource().getFilename();if (!resource.getResource().exists()) {assert sourceName != null;return new PropertiesPropertySource(sourceName, new Properties());} else {assert sourceName != null;if (sourceName.endsWith(".yml") || sourceName.endsWith(".yaml")) {Properties propertiesFromYaml = loadYml(resource);return new PropertiesPropertySource(sourceName, propertiesFromYaml);} else {return super.createPropertySource(name, resource);}}}private Properties loadYml(EncodedResource resource) throws IOException {YamlPropertiesFactoryBean factory = new YamlPropertiesFactoryBean();factory.setResources(resource.getResource());factory.afterPropertiesSet();return factory.getObject();}} -
创建请求基类BaseRequest
package com.abon.smart_family_lot.application.common.extend.request;/*** desc: 请求基类* author: zmq3821@163.com* date: 2021/12/6 9:58*/ public class BaseRequest {private String error = "";private Object result = "";public void setError(String error) {this.error = error;}public String getError() {return error;}public void setResult(Object result) {this.result = result;}public Object getResult() {return result;}} -
创建真正的请求封装类TuyaRequest.java
package com.abon.smart_family_lot.application.common.extend.request.tuya;import com.abon.smart_family_lot.application.common.exception.TuyaCloudSDKException; import com.abon.smart_family_lot.application.common.extend.request.BaseRequest; import com.abon.smart_family_lot.application.common.util.HttpUtil; import com.alibaba.fastjson.JSONObject; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component;import javax.annotation.Resource; import java.util.HashMap; import java.util.Map;/*** desc: 涂鸦平台请求封装* author: zmq3821@163.com* date: 2021/12/6 10:00*/ @Slf4j @Component public class TuyaRequest extends BaseRequest {@Resourceprivate TuyaRequestHelper tuyaRequestHelper;// GET请求public boolean doGetRequest(String uri, Map - 创建请求的助手类TuyaRequestHelper，请求的授权签名和header处理都在这里了
package com.abon.smart_family_lot.application.common.extend.request.tuya;import com.abon.smart_family_lot.application.common.config.TuyaCloudConfig; import com.abon.smart_family_lot.application.common.extend.request.BaseRequest; import com.abon.smart_family_lot.application.common.util.Sha256Util; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Component;import javax.annotation.Resource; import java.net.URL; import java.net.URLDecoder; import java.nio.charset.StandardCharsets; import java.util.Arrays; import java.util.HashMap; import java.util.Map; import java.util.TreeMap; import java.util.stream.Collectors;/*** desc: 涂鸦平台API SIGN辅助类* author: zmq3821@163.com* date: 2021/12/6 10:00*/ @Slf4j @Component public class TuyaRequestHelper extends BaseRequest {// 当body为空时的SHA256值private static final String EMPTY_HASH = "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855";// 需要参与签名的Header的keyprivate static final String SING_HEADER_NAME = "Signature-Headers";@Resourceprivate TuyaCloudConfig tuyaCloudConfig;@Resourceprivate TuyaRequestAccessToken tuyaRequestAccessToken;// header请求头参数初始化public Map4
-
还要创建accessToekn管理类TuyaRequestAccessToken
简单来说是把获取到的accessToken和refreshToken分别放入缓存中，若accessToken缓存到期则使用refreshToken刷新Token并再次放入缓存；TuyaRequestAccessToken由此实现了token的管理，而在请求内只需调用而无需关心accessToken的获取逻辑
package com.abon.smart_family_lot.application.common.extend.request.tuya;import com.abon.smart_family_lot.application.common.exception.TuyaCloudSDKException; import com.abon.smart_family_lot.application.common.extend.request.BaseRequest; import com.abon.smart_family_lot.application.common.util.DateUtil; import com.abon.smart_family_lot.application.common.util.HttpUtil; import com.abon.smart_family_lot.application.common.util.RedisCacheUtil; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component;import javax.annotation.Resource; import java.io.Serializable; import java.util.Map;/*** desc: 涂鸦平台API accessToekn管理类* author: zmq3821@163.com* date: 2021/12/6 10:00*/ @Slf4j @Component public class TuyaRequestAccessToken {// accessToken的缓存键private final String cacheAccessTokenKey = "TUYA_API_ACCESS_TOKEN";// refreshToken的缓存键private final String cacheRefreshTokenKey = "TUYA_API_REFRESH_ACCESS_TOKEN";@Resourceprivate TuyaRequestHelper tuyaRequestSign;@Resourceprivate RedisCacheUtil redisCacheUtil;@Data@NoArgsConstructor // 注解在类上；为类提供一个无参的构造方法@AllArgsConstructor // 注解在类上；为类提供一个全参的构造方法public static class TokenVO implements Serializable {private String accessToken;private String refreshToken;private long expireTime;}// 获取AccessTokenprivate void createAccessToken() {log.info("获取AccessToken");try {String uri = "/v1.0/token?grant_type=1";String url = tuyaRequestSign.getUrlStr(uri, null);Map -
最后示例一个GET请求的调用
public boolean info(DeviceValidate.infoTDO params) {String deviceId = params.getDeviceId();boolean res = tuyaRequest.doGetRequest("/v1.0/devices/" + deviceId, null);if (!res) {setError(tuyaRequest.getError());return false;}JSONObject data = JSONObject.parseObject(tuyaRequest.getResult().toString());setResult(data);return true;}
8.应某位小伙伴的要求再补加一个Sha256Util工具类
package com.abon.smart_family_lot.application.common.util;import javax.crypto.Mac;
import javax.crypto.SecretKey;
import javax.crypto.spec.SecretKeySpec;
import javax.xml.bind.annotation.adapters.HexBinaryAdapter;
import java.nio.charset.StandardCharsets;
import java.security.InvalidKeyException;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;/*** desc: Sha256工具类* author: zmq3821@163.com* date: 2021/12/3 16:07*/
public class Sha256Util {public static String encryption(String str) throws Exception {return encryption(str.getBytes(StandardCharsets.UTF_8));}public static String encryption(byte[] buf) throws Exception {MessageDigest messageDigest;messageDigest = MessageDigest.getInstance("SHA-256");messageDigest.update(buf);return byte2Hex(messageDigest.digest());}private static String byte2Hex(byte[] bytes) {StringBuilder stringBuffer = new StringBuilder();String temp;for (byte aByte : bytes) {temp = Integer.toHexString(aByte & 0xFF);if (temp.length() == 1) {stringBuffer.append("0");}stringBuffer.append(temp);}return stringBuffer.toString();}public static String sha256HMAC(String content, String secret) {Mac sha256HMAC = null;try {sha256HMAC = Mac.getInstance("HmacSHA256");} catch (NoSuchAlgorithmException e) {e.printStackTrace();}SecretKey secretKey = new SecretKeySpec(secret.getBytes(StandardCharsets.UTF_8), "HmacSHA256");try {assert sha256HMAC != null;sha256HMAC.init(secretKey);} catch (InvalidKeyException e) {e.printStackTrace();}byte[] digest = sha256HMAC.doFinal(content.getBytes(StandardCharsets.UTF_8));return new HexBinaryAdapter().marshal(digest).toUpperCase();}}
本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！