需求:
1 手机号在数据库中是使用rsa方式加密存储,后台查看中需要转换为明文,因为需要解密多个手机号,所以在后台查看中消耗时间3秒,希望通过多线程,多进程,异步方式来缩短时间
相关注意点:
Django遵循单请求模型,其中每个请求都在单个线程中处理。在Django的请求 / 响应周期中引入多线程可能无法提供预期的性能提升
据库访问是一个常见的瓶颈,如果数据库连接池不是线程安全的,或者数据库服务器本身无法有效地处理并发连接,则引入多线程可能没有好处。
1:使用异步方式 进行手机号解密–消耗时间1秒
但是,在后台中无法显示手机号
2:使用多线程进行手机号进行解密,消耗时间3秒
3使用多进程来进行手机号解密–直接报错
额,我技术差
4:普通调用对手机号进行解密:消耗3秒
结论:普通调用就好,不用多线程,多进程,异步了
1:使用异步方式 进行手机号解密–消耗时间1秒
但是,在后台中无法显示手机号
# -------------------------------------------------------------------------------------
# 手机号解密
# 使用异步方式
async def decrypt_data_async(self, data):
# 读取私钥文件
private_key="""-----BEGIN RSA PRIVATE KEY-----
ekDfPc/BqzRSIkACEijwdnf7NhQveCAiE+aj5NiGkwS/zjX9S96v0qK5SFil6y+c
EXv1GMN54aCmiHWBGq86tOKjV9M4hnlVpuRJPeHi52nAyHpJfmB7
-----END RSA PRIVATE KEY-----"""
key = serialization.load_pem_private_key(private_key.encode(), password=None, backend=default_backend())
decrypted_data = key.decrypt(data, padding.OAEP(mgf=padding.MGF1(algorithm=hashes.SHA256()),
algorithm=hashes.SHA256(), label=None)).decode('utf-8')
return decrypted_data
async def get_shoujihao(self):
if len(self.shoujihao) >= 20:
shoujihao1 = self.shoujihao
shoujihao1 = base64.b64decode(shoujihao1)
# Split the data into chunks for parallel decryption
chunk_size = 8000 # Adjust the chunk size based on your data
chunks = [shoujihao1[i:i + chunk_size] for i in range(0, len(shoujihao1), chunk_size)]
# Use asyncio.gather to concurrently decrypt chunks
decrypted_chunks = await asyncio.gather(*(self.decrypt_data_async(chunk) for chunk in chunks))
# Concatenate the decrypted chunks
decrypted_data = ''.join(decrypted_chunks)
color_code = 'green'
return format_html('<span style="color:{};">{}</span>', color_code, decrypted_data)
else:
color_code = 'green'
return format_html('<span style="color:{};">-</span>', color_code, )
get_shoujihao.short_description = '手机号'
# -------------------------------------------------------------------------------------
2:使用多线程进行手机号进行解密,消耗时间3秒
# --------------------------------------------------------------------------------------
# 使用多线程进行解密
from concurrent.futures import ThreadPoolExecutor
# --------------------------------------------------------------------------------------
# -------------------------------------------------------------------------------------
# 手机号解密
# 使用了多线程方式去进行解密
def get_shoujihao(self):
# 1:获取到数据库中的字符串 a
# 2:把字符串转换成字节类型 b
# 3:对字节b进行解密为 c
# 4:返回c
if len(self.shoujihao)>=20:
shoujihao1=self.shoujihao
shoujihao1 = base64.b64decode(shoujihao1)
# 读取私钥文件
private_key="""-----BEGIN RSA PRIVATE KEY-----
ekDfPc/BqzRSIkACEijwdnf7NhQveCAiE+aj5NiGkwS/zjX9S96v0qK5SFil6y+c
EXv1GMN54aCmiHWBGq86tOKjV9M4hnlVpuRJPeHi52nAyHpJfmB7
-----END RSA PRIVATE KEY-----"""
key = serialization.load_pem_private_key(private_key.encode(), password=None, backend=default_backend())
def decrypt_data(data):
return key.decrypt(data, padding.OAEP(mgf=padding.MGF1(algorithm=hashes.SHA256()),
algorithm=hashes.SHA256(), label=None)).decode('utf-8')
# 将数据拆分为块以进行并行解密
chunk_size = 1000 # 根据数据调整区块大小
chunks = [shoujihao1[i:i + chunk_size] for i in range(0, len(shoujihao1), chunk_size)]
# 使用 ThreadPoolExecutor 进行并行解密
with ThreadPoolExecutor() as executor:
decrypted_chunks = list(executor.map(decrypt_data, chunks))
# 连接解密的块
decrypted_data = ''.join(decrypted_chunks)
color_code = 'green'
return format_html('<span style="color:{};">{}</span>', color_code, decrypted_data)
else:
color_code = 'green'
return format_html('<span style="color:{};">-</span>', color_code, )
get_shoujihao.short_description = '手机号'
# -------------------------------------------------------------------------------------
3使用多进程来进行手机号解密–直接报错,额,我技术差文章来源:https://www.toymoban.com/news/detail-810649.html
# --------------------------------------------------------------------------------------
# 使用多进程进行解密
import logging
from concurrent.futures import ProcessPoolExecutor
logger = logging.getLogger(__name__)
# --------------------------------------------------------------------------------------
# -------------------------------------------------------------------------------------
# 手机号解密
# 使用了多进程方式去进行解密
def decrypt_data(self, data):
try:
# 读取私钥文件
private_key="""-----BEGIN RSA PRIVATE KEY-----
ekDfPc/BqzRSIkACEijwdnf7NhQveCAiE+aj5NiGkwS/zjX9S96v0qK5SFil6y+c
EXv1GMN54aCmiHWBGq86tOKjV9M4hnlVpuRJPeHi52nAyHpJfmB7
-----END RSA PRIVATE KEY-----"""
key = serialization.load_pem_private_key(private_key.encode(), password=None, backend=default_backend())
return key.decrypt(data, padding.OAEP(mgf=padding.MGF1(algorithm=hashes.SHA256()),
algorithm=hashes.SHA256(), label=None)).decode('utf-8')
except Exception as e:
logger.error(f"Error in decryption: {e}")
raise
def get_shoujihao(self):
if len(self.shoujihao) >= 20:
shoujihao1 = self.shoujihao
shoujihao1 = base64.b64decode(shoujihao1)
# 将数据拆分为块以进行并行解密
chunk_size = 1000 # 根据数据调整区块大小
chunks = [shoujihao1[i:i + chunk_size] for i in range(0, len(shoujihao1), chunk_size)]
# 使用 ProcessPoolExecutor 进行并行解密
with ProcessPoolExecutor(max_workers=2) as executor:
decrypted_chunks = list(executor.map(self.decrypt_data, chunks))
# 连接解密的块
decrypted_data = ''.join(decrypted_chunks)
color_code = 'green'
return format_html('<span style="color:{};">{}</span>', color_code, decrypted_data)
else:
color_code = 'green'
return format_html('<span style="color:{};">-</span>', color_code, )
get_shoujihao.short_description = '手机号'
# -------------------------------------------------------------------------------------
4:普通调用对手机号进行解密:消耗3秒文章来源地址https://www.toymoban.com/news/detail-810649.html
# -------------------------------------------------------------------------------------
# 手机号解密
def get_shoujihao(self):
# 1:获取到数据库中的字符串 a
# 2:把字符串转换成字节类型 b
# 3:对字节b进行解密为 c
# 4:返回c
if len(self.shoujihao)>=20:
shoujihao1=self.shoujihao
shoujihao1 = base64.b64decode(shoujihao1)
# 读取私钥文件
private_key="""-----BEGIN RSA PRIVATE KEY-----
ekDfPc/BqzRSIkACEijwdnf7NhQveCAiE+aj5NiGkwS/zjX9S96v0qK5SFil6y+c
EXv1GMN54aCmiHWBGq86tOKjV9M4hnlVpuRJPeHi52nAyHpJfmB7
-----END RSA PRIVATE KEY-----"""
key = serialization.load_pem_private_key(private_key.encode(), password=None, backend=default_backend())
decrypted_data = key.decrypt(shoujihao1, padding.OAEP(mgf=padding.MGF1(algorithm=hashes.SHA256()),
algorithm=hashes.SHA256(), label=None))
# decrypted_data 的类型为字节
decrypted_data=decrypted_data.decode('utf-8')
# decrypted_data.decode()之后的类型为字符串
shoujihao1=decrypted_data
# print("类型")
# print(type(decrypted_data))
# print(decrypted_data)
# 打印解密后的消息
color_code = 'green'
return format_html('<span style="color:{};">{}</span>', color_code, shoujihao1)
else:
color_code = 'green'
return format_html('<span style="color:{};">-</span>', color_code, )
get_shoujihao.short_description = '手机号'
# -------------------------------------------------------------------------------------
到了这里,关于django admin后台中进行多个手机号解密消耗时间对比的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!