From 456916599340e8cfb7bdcb21d70185d7920b50b8 Mon Sep 17 00:00:00 2001 From: = <=> Date: Fri, 10 Nov 2023 16:37:30 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E5=AF=86=E7=AE=97=E6=B3=95=E6=94=B9?= =?UTF-8?q?=E4=B8=BAAES?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../handler/ProxyMessageAuthHandler.java | 6 ++-- .../handler/ProxyMessageConnectHandler.java | 1 + .../handler/ProxyMessageSecureKeyHandler.java | 8 +++-- .../neutrinoproxy/client/util/ProxyUtil.java | 11 +++++++ .../neutrinoproxy/core/ProxyMessage.java | 4 +-- .../core/ProxyMessageDecoder.java | 11 +++++-- .../core/ProxyMessageEncoder.java | 7 ++-- .../{SmEncryptUtil.java => EncryptUtil.java} | 33 +++++++++++++++++-- .../handler/ProxyMessageAuthHandler.java | 10 +++--- .../handler/ProxyMessageConnectHandler.java | 3 ++ .../handler/ProxyMessageSecureKeyHandler.java | 25 +++++++++----- .../neutrinoproxy/server/util/ProxyUtil.java | 26 +++++++++++++++ 12 files changed, 119 insertions(+), 26 deletions(-) rename neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/util/{SmEncryptUtil.java => EncryptUtil.java} (77%) diff --git a/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/handler/ProxyMessageAuthHandler.java b/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/handler/ProxyMessageAuthHandler.java index 233d23d3..c8f4f6ec 100644 --- a/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/handler/ProxyMessageAuthHandler.java +++ b/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/handler/ProxyMessageAuthHandler.java @@ -9,7 +9,7 @@ import org.dromara.neutrinoproxy.core.ExceptionEnum; import org.dromara.neutrinoproxy.core.ProxyMessage; import org.dromara.neutrinoproxy.core.ProxyMessageHandler; import org.dromara.neutrinoproxy.core.dispatcher.Match; -import org.dromara.neutrinoproxy.core.util.SmEncryptUtil; +import org.dromara.neutrinoproxy.core.util.EncryptUtil; import org.noear.snack.ONode; import org.noear.solon.Solon; import org.noear.solon.annotation.Component; @@ -51,13 +51,13 @@ public class ProxyMessageAuthHandler implements ProxyMessageHandler { // 获取认证成功的后的公钥信息，并生成随机密码，加密发到服务端确认 String publicKey = load.get("publicKey").getString(); - byte[] secureKey = SmEncryptUtil.generateSm4Key(); + byte[] secureKey = EncryptUtil.generateAesKey(); // 存储密码 Attribute secureKeyAttr = context.attr(Constants.SECURE_KEY); secureKeyAttr.set(secureKey); // 使用SM2算法对密钥进行加密并发送到服务端 - byte[] encryptSecureKey = SmEncryptUtil.encryptBySm2(publicKey, secureKey); + byte[] encryptSecureKey = EncryptUtil.encryptBySm2(publicKey, secureKey); context.writeAndFlush(ProxyMessage.buildSecureKeyMessage(encryptSecureKey)); context.flush(); } diff --git a/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/handler/ProxyMessageConnectHandler.java b/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/handler/ProxyMessageConnectHandler.java index 2bca8667..9d88918e 100644 --- a/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/handler/ProxyMessageConnectHandler.java +++ b/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/handler/ProxyMessageConnectHandler.java @@ -62,6 +62,7 @@ public class ProxyMessageConnectHandler implements ProxyMessageHandler { realServerChannel.config().setOption(ChannelOption.AUTO_READ, true); ProxyUtil.addRealServerChannel(visitorId, realServerChannel); ProxyUtil.setRealServerChannelVisitorId(realServerChannel, visitorId); + ProxyUtil.setChannelSecurity(channel); } @Override diff --git a/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/handler/ProxyMessageSecureKeyHandler.java b/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/handler/ProxyMessageSecureKeyHandler.java index 67080776..2c302a15 100644 --- a/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/handler/ProxyMessageSecureKeyHandler.java +++ b/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/handler/ProxyMessageSecureKeyHandler.java @@ -3,11 +3,12 @@ package org.dromara.neutrinoproxy.client.handler; import io.netty.channel.ChannelHandlerContext; import io.netty.util.Attribute; import lombok.extern.slf4j.Slf4j; +import org.dromara.neutrinoproxy.client.util.ProxyUtil; import org.dromara.neutrinoproxy.core.Constants; import org.dromara.neutrinoproxy.core.ProxyMessage; import org.dromara.neutrinoproxy.core.ProxyMessageHandler; import org.dromara.neutrinoproxy.core.dispatcher.Match; -import org.dromara.neutrinoproxy.core.util.SmEncryptUtil; +import org.dromara.neutrinoproxy.core.util.EncryptUtil; import org.noear.solon.annotation.Component; @Slf4j @@ -20,12 +21,15 @@ public class ProxyMessageSecureKeyHandler implements ProxyMessageHandler { Attribute secureKeyAttr = ctx.attr(Constants.SECURE_KEY); byte[] secureKey = secureKeyAttr.get(); byte[] data = proxyMessage.getData(); - byte[] decryptedData = SmEncryptUtil.decryptBySm4(secureKey, data); + byte[] decryptedData = EncryptUtil.decryptByAes(secureKey, data); String m = new String(decryptedData); if ("ok".equals(m)) { // 设置当前链路为安全，之后使用该链路传输的消息均会加密 Attribute booleanAttribute = ctx.attr(Constants.IS_SECURITY); booleanAttribute.set(true); + + ProxyUtil.setSecureKey(secureKey); + log.info("Encrypted link established successfully"); } else { ctx.channel().close(); diff --git a/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/util/ProxyUtil.java b/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/util/ProxyUtil.java index b44bd4a9..22332a3a 100644 --- a/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/util/ProxyUtil.java +++ b/neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/util/ProxyUtil.java @@ -72,6 +72,8 @@ public class ProxyUtil { private static String clientId; private static final String CLIENT_ID_FILE = ".NEUTRINO_PROXY_CLIENT_ID"; + private static byte[] secureKey; + public static void borrowTcpProxyChanel(Bootstrap tcpProxyTunnelBootstrap, final ProxyChannelBorrowListener borrowListener) { Channel channel = tcpProxyChannelPool.poll(); if (null != channel) { @@ -223,4 +225,13 @@ public class ProxyUtil { return null; } + public static void setSecureKey(byte[] key) { + secureKey = key; + } + + public static void setChannelSecurity(Channel channel) { + channel.attr(Constants.IS_SECURITY).set(true); + channel.attr(Constants.SECURE_KEY).set(secureKey); + } + } diff --git a/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/ProxyMessage.java b/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/ProxyMessage.java index 0da050fe..c30d513e 100644 --- a/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/ProxyMessage.java +++ b/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/ProxyMessage.java @@ -24,7 +24,7 @@ package org.dromara.neutrinoproxy.core; import lombok.Data; import lombok.experimental.Accessors; -import org.dromara.neutrinoproxy.core.util.SmEncryptUtil; +import org.dromara.neutrinoproxy.core.util.EncryptUtil; import org.noear.snack.ONode; import java.util.Arrays; @@ -145,7 +145,7 @@ public class ProxyMessage { public static ProxyMessage buildSecureKeyMessage(byte[] secureKey) { return create().setType(TYPE_SECURE_KEY) - .setInfo(SmEncryptUtil.digestBySm3(secureKey)) + .setInfo(EncryptUtil.digestBySm3(secureKey)) .setData(secureKey); } diff --git a/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/ProxyMessageDecoder.java b/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/ProxyMessageDecoder.java index 4c1869ec..654c10d5 100644 --- a/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/ProxyMessageDecoder.java +++ b/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/ProxyMessageDecoder.java @@ -22,13 +22,14 @@ package org.dromara.neutrinoproxy.core; +import cn.hutool.core.util.HexUtil; import io.netty.buffer.ByteBuf; import io.netty.buffer.Unpooled; import io.netty.channel.ChannelHandlerContext; import io.netty.handler.codec.LengthFieldBasedFrameDecoder; import io.netty.util.Attribute; import lombok.extern.slf4j.Slf4j; -import org.dromara.neutrinoproxy.core.util.SmEncryptUtil; +import org.dromara.neutrinoproxy.core.util.EncryptUtil; import static org.dromara.neutrinoproxy.core.Constants.*; @@ -97,7 +98,9 @@ public class ProxyMessageDecoder extends LengthFieldBasedFrameDecoder { Attribute secureKeyAttr = ctx.attr(SECURE_KEY); byte[] secureKey = secureKeyAttr.get(); // 解密 - byte[] decryptedData = SmEncryptUtil.decryptBySm4(secureKey, encryptedBytes); + log.info("DecoderKey:{}", HexUtil.encodeHexStr(secureKey)); + log.info("DecoderBytes:{}", HexUtil.encodeHexStr(encryptedBytes)); + byte[] decryptedData = EncryptUtil.decryptByAes(secureKey, encryptedBytes); buf = Unpooled.wrappedBuffer(decryptedData); } else { @@ -124,6 +127,10 @@ public class ProxyMessageDecoder extends LengthFieldBasedFrameDecoder { buf.release(); + if (isSecurity != null && isSecurity) { + log.info("【ProxyMessage】-type:{},编码解密", proxyMessage.getType()); + } + return proxyMessage; } } diff --git a/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/ProxyMessageEncoder.java b/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/ProxyMessageEncoder.java index a8c660a5..c560ab15 100644 --- a/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/ProxyMessageEncoder.java +++ b/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/ProxyMessageEncoder.java @@ -28,7 +28,7 @@ import io.netty.channel.ChannelHandlerContext; import io.netty.handler.codec.MessageToByteEncoder; import io.netty.util.Attribute; import lombok.extern.slf4j.Slf4j; -import org.dromara.neutrinoproxy.core.util.SmEncryptUtil; +import org.dromara.neutrinoproxy.core.util.EncryptUtil; import static org.dromara.neutrinoproxy.core.Constants.*; @@ -89,6 +89,9 @@ public class ProxyMessageEncoder extends MessageToByteEncoder { // 考虑isSecurity为null的情况，null的情况也为false if (isSecurity != null && isSecurity) { + + log.info("【ProxyMessage】-type:{},编码加密", msg.getType()); + // 执行加密 byte[] data = new byte[buf.writerIndex()]; buf.readBytes(data); @@ -97,7 +100,7 @@ public class ProxyMessageEncoder extends MessageToByteEncoder { Attribute secureKeyAttr = ctx.attr(SECURE_KEY); byte[] secureKey = secureKeyAttr.get(); // 执行加密 - byte[] encryptedData = SmEncryptUtil.encryptBySm4(secureKey, data); + byte[] encryptedData = EncryptUtil.encryptByAes(secureKey, data); out.writeInt(encryptedData.length); out.writeBytes(encryptedData); buf.release(); diff --git a/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/util/SmEncryptUtil.java b/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/util/EncryptUtil.java similarity index 77% rename from neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/util/SmEncryptUtil.java rename to neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/util/EncryptUtil.java index 10c67de4..6a660419 100644 --- a/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/util/SmEncryptUtil.java +++ b/neutrino-proxy-core/src/main/java/org/dromara/neutrinoproxy/core/util/EncryptUtil.java @@ -25,6 +25,8 @@ package org.dromara.neutrinoproxy.core.util; import cn.hutool.core.util.HexUtil; import cn.hutool.crypto.SecureUtil; import cn.hutool.crypto.SmUtil; +import cn.hutool.crypto.symmetric.SymmetricAlgorithm; +import cn.hutool.crypto.symmetric.SymmetricCrypto; import org.dromara.neutrinoproxy.core.KeyPairRecord; import javax.crypto.SecretKey; @@ -35,7 +37,7 @@ import java.security.KeyPair; * @author: az * @date: 2023/11/07 */ -public class SmEncryptUtil { +public class EncryptUtil { /** * 生成SM2密钥对 @@ -73,8 +75,7 @@ public class SmEncryptUtil { } public static byte[] generateSm4Key() { - SecretKey key = SecureUtil.generateKey("AES", 128); - return key.getEncoded(); + return SecureUtil.generateKey("AES", 128).getEncoded(); } /** @@ -97,6 +98,32 @@ public class SmEncryptUtil { return SmUtil.sm4(key).decrypt(encryptedData); } + public static byte[] generateAesKey() { + return SecureUtil.generateKey(SymmetricAlgorithm.AES.getValue()).getEncoded(); + } + + /** + * 使用AES算法加密数据 + * @param key 密钥 + * @param data 被加密数据 + * @return 加密后的数据 + */ + public static byte[] encryptByAes(byte[] key, byte[] data) { + SymmetricCrypto aes = new SymmetricCrypto(SymmetricAlgorithm.AES, key); + return aes.encrypt(data); + } + + /** + * 使用AES法解密数据 + * @param key 密钥 + * @param encryptedData 已加密数据 + * @return 解密后的数据 + */ + public static byte[] decryptByAes(byte[] key, byte[] encryptedData) { + SymmetricCrypto aes = new SymmetricCrypto(SymmetricAlgorithm.AES, key); + return aes.decrypt(encryptedData); + } + /** * 使用SM3算法对内容生成摘要 * @param data diff --git a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/handler/ProxyMessageAuthHandler.java b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/handler/ProxyMessageAuthHandler.java index 5ba72341..297a11bb 100644 --- a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/handler/ProxyMessageAuthHandler.java +++ b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/handler/ProxyMessageAuthHandler.java @@ -26,7 +26,7 @@ import cn.hutool.core.util.StrUtil; import io.netty.util.Attribute; import org.dromara.neutrinoproxy.core.*; import org.dromara.neutrinoproxy.core.dispatcher.Match; -import org.dromara.neutrinoproxy.core.util.SmEncryptUtil; +import org.dromara.neutrinoproxy.core.util.EncryptUtil; import org.dromara.neutrinoproxy.server.base.proxy.ProxyConfig; import org.dromara.neutrinoproxy.server.constant.ClientConnectTypeEnum; import org.dromara.neutrinoproxy.server.constant.EnableStatusEnum; @@ -173,11 +173,13 @@ public class ProxyMessageAuthHandler implements ProxyMessageHandler { booleanAttribute.set(false); // 生成获取SM2密钥对,私钥存入ctx，公钥拼装参数随Auth数据包返回 - KeyPairRecord record = SmEncryptUtil.generateSm2KeyPair(); + KeyPairRecord record = EncryptUtil.generateSm2KeyPair(); // 私钥存入ctx - Attribute attr = ctx.attr(Constants.SECURE_PRIVATE_KEY); - attr.set(record.privateKey()); + ctx.attr(Constants.SECURE_PRIVATE_KEY).set(record.privateKey()); + + // 存储licenseId + ctx.attr(Constants.LICENSE_ID).set(licenseDO.getId()); // 发送认证成功消息 ctx.channel().writeAndFlush(ProxyMessage.buildAuthResultMessage(ExceptionEnum.SUCCESS.getCode(), "auth success!", licenseKey, record.publicKey())); diff --git a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/handler/ProxyMessageConnectHandler.java b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/handler/ProxyMessageConnectHandler.java index a638f4a0..16eb889a 100644 --- a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/handler/ProxyMessageConnectHandler.java +++ b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/handler/ProxyMessageConnectHandler.java @@ -92,6 +92,9 @@ public class ProxyMessageConnectHandler implements ProxyMessageHandler { ProxyUtil.remoteProxyConnectAttachment(visitorId); proxyAttachment.execute(); } + + // 设置加密 + ProxyUtil.setChannelSecurity(licenseDO.getId(), visitorChannel); } @Override diff --git a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/handler/ProxyMessageSecureKeyHandler.java b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/handler/ProxyMessageSecureKeyHandler.java index 9ace39a5..4c7aa455 100644 --- a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/handler/ProxyMessageSecureKeyHandler.java +++ b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/handler/ProxyMessageSecureKeyHandler.java @@ -1,18 +1,21 @@ package org.dromara.neutrinoproxy.server.proxy.handler; import cn.hutool.core.util.StrUtil; +import io.netty.channel.Channel; import io.netty.channel.ChannelHandlerContext; import io.netty.util.Attribute; -import io.netty.util.AttributeKey; import lombok.extern.slf4j.Slf4j; import org.dromara.neutrinoproxy.core.Constants; import org.dromara.neutrinoproxy.core.ProxyDataTypeEnum; import org.dromara.neutrinoproxy.core.ProxyMessage; import org.dromara.neutrinoproxy.core.ProxyMessageHandler; import org.dromara.neutrinoproxy.core.dispatcher.Match; -import org.dromara.neutrinoproxy.core.util.SmEncryptUtil; +import org.dromara.neutrinoproxy.core.util.EncryptUtil; +import org.dromara.neutrinoproxy.server.util.ProxyUtil; import org.noear.solon.annotation.Component; +import java.util.Map; + @Slf4j @Match(type= Constants.ProxyDataTypeName.SECURE_KEY) @Component @@ -27,7 +30,7 @@ public class ProxyMessageSecureKeyHandler implements ProxyMessageHandler { byte[] data = proxyMessage.getData(); String receivedDigest = proxyMessage.getInfo(); - String digest = SmEncryptUtil.digestBySm3(data); + String digest = EncryptUtil.digestBySm3(data); if (!digest.equals(receivedDigest)) { // 获取加密信息失败 log.warn("密码协商失败"); @@ -46,22 +49,28 @@ public class ProxyMessageSecureKeyHandler implements ProxyMessageHandler { } // 解密传输密码 - byte[] secureKey = SmEncryptUtil.decryptBySm2(privateKey, data); + byte[] secureKey = EncryptUtil.decryptBySm2(privateKey, data); // 传输密码存储ctx中 Attribute secureKeyAttr = ctx.attr(Constants.SECURE_KEY); secureKeyAttr.setIfAbsent(secureKey); // 使用密码加密success给客户端表示密码已确认 - byte[] encryptedSuccessInfoData = SmEncryptUtil.encryptBySm4(secureKey, "ok".getBytes()); + byte[] encryptedSuccessInfoData = EncryptUtil.encryptByAes(secureKey, "ok".getBytes()); // 发送回去，以示确认 ctx.writeAndFlush(ProxyMessage.buildSecureKeyReturnMessage(encryptedSuccessInfoData)); ctx.flush(); - // 设置链路状态为安全，之后使用该链路传输的均会加密 - Attribute booleanAttribute = ctx.attr(Constants.IS_SECURITY); - booleanAttribute.set(true); + // 设置该链路以及相关链路状态为安全，之后使用链路传输的数据均会加密 + Integer licenseId = ctx.attr(Constants.LICENSE_ID).get(); + ProxyUtil.setSecureKey(licenseId, secureKey); + ProxyUtil.setChannelSecurity(licenseId, ctx.channel()); + Map channelMap = ProxyUtil.getVisitorChannels(ctx.channel()); + channelMap.values().forEach(channel -> ProxyUtil.setChannelSecurity(licenseId, channel)); + if (licenseId != null) { + ProxyUtil.setLicenseIdRelativeChannelSecurity(licenseId); + } } @Override diff --git a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/util/ProxyUtil.java b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/util/ProxyUtil.java index 14ecd297..7ae1d3b5 100644 --- a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/util/ProxyUtil.java +++ b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/util/ProxyUtil.java @@ -69,6 +69,8 @@ public class ProxyUtil { */ private static Map licenseIdToClientIdMap = new HashMap<>(); + private static Map licenseIdToSecureKeyMap = new ConcurrentHashMap<>(); + /** * 初始化代理信息 * @param licenseId licenseId @@ -144,6 +146,9 @@ public class ProxyUtil { cmdChannelAttachInfo.getServerPorts().addAll(serverPorts); } + // 添加安全信息 + setChannelSecurity(licenseId, cmdChannel); + licenseToCmdChannelMap.put(licenseId, cmdChannel); } @@ -421,4 +426,25 @@ public class ProxyUtil { public static void removeClientIdByLicenseId(Integer licenseId) { licenseIdToClientIdMap.remove(licenseId); } + + public static void setSecureKey(Integer licenseId, byte[] key) { + licenseIdToSecureKeyMap.put(licenseId, key); + } + + public static void setLicenseIdRelativeChannelSecurity(Integer licenseId) { + Set portSet = licenseToServerPortMap.get(licenseId); + for(Integer port : portSet) { + Channel cmdChannel = serverPortToCmdChannelMap.get(port); + setChannelSecurity(licenseId, cmdChannel); + Channel visitorChannel = serverPortToVisitorChannel.get(port); + setChannelSecurity(licenseId,visitorChannel); + } + } + + public static void setChannelSecurity(Integer licenseId, Channel channel) { + if (channel != null && licenseIdToSecureKeyMap.containsKey(licenseId)) { + channel.attr(Constants.IS_SECURITY).set(true); + channel.attr(Constants.SECURE_KEY).set(licenseIdToSecureKeyMap.get(licenseId)); + } + } }