|
|
|
|
@ -0,0 +1,246 @@
|
|
|
|
|
from Crypto.Hash import MD4
|
|
|
|
|
import threading
|
|
|
|
|
import random
|
|
|
|
|
import string
|
|
|
|
|
import queue
|
|
|
|
|
import Db
|
|
|
|
|
|
|
|
|
|
lock = threading.Lock()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def md4(input_string):
|
|
|
|
|
# 将密码编码为 UTF-16LE
|
|
|
|
|
password_utf16 = input_string.encode('utf-16le')
|
|
|
|
|
|
|
|
|
|
# 创建新的 MD4 哈希对象
|
|
|
|
|
md4_hasher = MD4.new()
|
|
|
|
|
|
|
|
|
|
# 更新 MD4 哈希对象
|
|
|
|
|
md4_hasher.update(password_utf16)
|
|
|
|
|
|
|
|
|
|
# 获取哈希值的十六进制表示
|
|
|
|
|
ntlm_hash_hex = md4_hasher.hexdigest()
|
|
|
|
|
|
|
|
|
|
return ntlm_hash_hex
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class Rainbow_Cain:
|
|
|
|
|
def __init__(self, length, charset='abcdefghijklmnopqrstuvwxyz0123456789'):
|
|
|
|
|
self.length = length
|
|
|
|
|
self.charset = charset
|
|
|
|
|
self.db = Db.Db_Operation()
|
|
|
|
|
|
|
|
|
|
def R1(self, hash_value):
|
|
|
|
|
reduced_value = ''
|
|
|
|
|
for i in range(self.length):
|
|
|
|
|
index = int(hash_value[i * 2:i * 2 + 2], 16) % len(self.charset)
|
|
|
|
|
reduced_value += self.charset[index]
|
|
|
|
|
return reduced_value
|
|
|
|
|
|
|
|
|
|
def R2(self, hash_value):
|
|
|
|
|
reduced_value = ''
|
|
|
|
|
for i in range(self.length):
|
|
|
|
|
slice_start = (i * 3 + int(hash_value[i % len(hash_value)], 16)) % len(hash_value)
|
|
|
|
|
slice_end = (slice_start + 2) % len(hash_value)
|
|
|
|
|
if slice_end < slice_start:
|
|
|
|
|
slice_combined = hash_value[slice_start:] + hash_value[:slice_end]
|
|
|
|
|
else:
|
|
|
|
|
slice_combined = hash_value[slice_start:slice_end]
|
|
|
|
|
index = int(slice_combined, 16) % len(self.charset)
|
|
|
|
|
reduced_value += self.charset[index]
|
|
|
|
|
return reduced_value
|
|
|
|
|
|
|
|
|
|
def R3(self, hash_value):
|
|
|
|
|
reduced_value = ''
|
|
|
|
|
for i in range(self.length):
|
|
|
|
|
slice_start = (i * 4 + int(hash_value[i * 2 % len(hash_value)], 16)) % len(hash_value)
|
|
|
|
|
slice_end = (slice_start + 3) % len(hash_value)
|
|
|
|
|
if slice_end < slice_start:
|
|
|
|
|
slice_combined = hash_value[slice_start:] + hash_value[:slice_end]
|
|
|
|
|
else:
|
|
|
|
|
slice_combined = hash_value[slice_start:slice_end]
|
|
|
|
|
index = int(slice_combined, 16) % len(self.charset)
|
|
|
|
|
reduced_value += self.charset[index]
|
|
|
|
|
return reduced_value
|
|
|
|
|
|
|
|
|
|
def R4(self, hash_value):
|
|
|
|
|
reduced_value = ''
|
|
|
|
|
for i in range(self.length):
|
|
|
|
|
slice_start = (i * 5 + int(hash_value[i * 3 % len(hash_value)], 16)) % len(hash_value)
|
|
|
|
|
slice_end = (slice_start + 4) % len(hash_value)
|
|
|
|
|
if slice_end < slice_start:
|
|
|
|
|
slice_combined = hash_value[slice_start:] + hash_value[:slice_end]
|
|
|
|
|
else:
|
|
|
|
|
slice_combined = hash_value[slice_start:slice_end]
|
|
|
|
|
index = int(slice_combined, 16) % len(self.charset)
|
|
|
|
|
reduced_value += self.charset[index]
|
|
|
|
|
return reduced_value
|
|
|
|
|
|
|
|
|
|
def R5(self, hash_value):
|
|
|
|
|
reduced_value = ''
|
|
|
|
|
for i in range(self.length):
|
|
|
|
|
slice_start = (i * 6 + int(hash_value[i * 4 % len(hash_value)], 16)) % len(hash_value)
|
|
|
|
|
slice_end = (slice_start + 5) % len(hash_value)
|
|
|
|
|
if slice_end < slice_start:
|
|
|
|
|
slice_combined = hash_value[slice_start:] + hash_value[:slice_end]
|
|
|
|
|
else:
|
|
|
|
|
slice_combined = hash_value[slice_start:slice_end]
|
|
|
|
|
index = int(slice_combined, 16) % len(self.charset)
|
|
|
|
|
reduced_value += self.charset[index]
|
|
|
|
|
return reduced_value
|
|
|
|
|
|
|
|
|
|
def R6(self, hash_value):
|
|
|
|
|
reduced_value = ''
|
|
|
|
|
for i in range(self.length):
|
|
|
|
|
slice_start = (i * 7 + int(hash_value[i * 5 % len(hash_value)], 16)) % len(hash_value)
|
|
|
|
|
slice_end = (slice_start + 6) % len(hash_value)
|
|
|
|
|
if slice_end < slice_start:
|
|
|
|
|
slice_combined = hash_value[slice_start:] + hash_value[:slice_end]
|
|
|
|
|
else:
|
|
|
|
|
slice_combined = hash_value[slice_start:slice_end]
|
|
|
|
|
index = int(slice_combined, 16) % len(self.charset)
|
|
|
|
|
reduced_value += self.charset[index]
|
|
|
|
|
return reduced_value
|
|
|
|
|
|
|
|
|
|
def R7(self, hash_value):
|
|
|
|
|
reduced_value = ''
|
|
|
|
|
for i in range(self.length):
|
|
|
|
|
slice_start = (i * 8 + int(hash_value[i * 6 % len(hash_value)], 16)) % len(hash_value)
|
|
|
|
|
slice_end = (slice_start + 7) % len(hash_value)
|
|
|
|
|
if slice_end < slice_start:
|
|
|
|
|
slice_combined = hash_value[slice_start:] + hash_value[:slice_end]
|
|
|
|
|
else:
|
|
|
|
|
slice_combined = hash_value[slice_start:slice_end]
|
|
|
|
|
index = int(slice_combined, 16) % len(self.charset)
|
|
|
|
|
reduced_value += self.charset[index]
|
|
|
|
|
return reduced_value
|
|
|
|
|
|
|
|
|
|
def R8(self, hash_value):
|
|
|
|
|
reduced_value = ''
|
|
|
|
|
for i in range(self.length):
|
|
|
|
|
slice_start = (i * 9 + int(hash_value[i * 7 % len(hash_value)], 16)) % len(hash_value)
|
|
|
|
|
slice_end = (slice_start + 8) % len(hash_value)
|
|
|
|
|
if slice_end < slice_start:
|
|
|
|
|
slice_combined = hash_value[slice_start:] + hash_value[:slice_end]
|
|
|
|
|
else:
|
|
|
|
|
slice_combined = hash_value[slice_start:slice_end]
|
|
|
|
|
index = int(slice_combined, 16) % len(self.charset)
|
|
|
|
|
reduced_value += self.charset[index]
|
|
|
|
|
return reduced_value
|
|
|
|
|
|
|
|
|
|
def R9(self, hash_value):
|
|
|
|
|
reduced_value = ''
|
|
|
|
|
for i in range(self.length):
|
|
|
|
|
slice_start = (i * 10 + int(hash_value[i * 8 % len(hash_value)], 16)) % len(hash_value)
|
|
|
|
|
slice_end = (slice_start + 9) % len(hash_value)
|
|
|
|
|
if slice_end < slice_start:
|
|
|
|
|
slice_combined = hash_value[slice_start:] + hash_value[:slice_end]
|
|
|
|
|
else:
|
|
|
|
|
slice_combined = hash_value[slice_start:slice_end]
|
|
|
|
|
index = int(slice_combined, 16) % len(self.charset)
|
|
|
|
|
reduced_value += self.charset[index]
|
|
|
|
|
return reduced_value
|
|
|
|
|
|
|
|
|
|
def R10(self, hash_value):
|
|
|
|
|
reduced_value = ''
|
|
|
|
|
for i in range(self.length):
|
|
|
|
|
slice_start = (i * 11 + int(hash_value[i * 9 % len(hash_value)], 16)) % len(hash_value)
|
|
|
|
|
slice_end = (slice_start + 10) % len(hash_value)
|
|
|
|
|
if slice_end < slice_start:
|
|
|
|
|
slice_combined = hash_value[slice_start:] + hash_value[:slice_end]
|
|
|
|
|
else:
|
|
|
|
|
slice_combined = hash_value[slice_start:slice_end]
|
|
|
|
|
index = int(slice_combined, 16) % len(self.charset)
|
|
|
|
|
reduced_value += self.charset[index]
|
|
|
|
|
return reduced_value
|
|
|
|
|
|
|
|
|
|
def Cain(self, random_str, K):
|
|
|
|
|
data_to_write = [] # 用于批量写入数据库的数据
|
|
|
|
|
for i in range(K):
|
|
|
|
|
hashcode = md4(random_str)
|
|
|
|
|
r_str = self.R1(hashcode)
|
|
|
|
|
hashcode = md4(r_str)
|
|
|
|
|
r_str = self.R2(hashcode)
|
|
|
|
|
hashcode = md4(r_str)
|
|
|
|
|
r_str = self.R3(hashcode)
|
|
|
|
|
hashcode = md4(r_str)
|
|
|
|
|
r_str = self.R4(hashcode)
|
|
|
|
|
hashcode = md4(r_str)
|
|
|
|
|
r_str = self.R5(hashcode)
|
|
|
|
|
hashcode = md4(r_str)
|
|
|
|
|
r_str = self.R6(hashcode)
|
|
|
|
|
hashcode = md4(r_str)
|
|
|
|
|
r_str = self.R7(hashcode)
|
|
|
|
|
hashcode = md4(r_str)
|
|
|
|
|
r_str = self.R8(hashcode)
|
|
|
|
|
hashcode = md4(r_str)
|
|
|
|
|
r_str = self.R9(hashcode)
|
|
|
|
|
hashcode = md4(r_str)
|
|
|
|
|
r_str = self.R10(hashcode)
|
|
|
|
|
|
|
|
|
|
data_to_write.append((random_str, r_str)) # 添加到批量写入列表
|
|
|
|
|
random_str = r_str
|
|
|
|
|
# 批量写入数据库
|
|
|
|
|
with lock:
|
|
|
|
|
self.db.write_to_database(data_to_write)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class Thread:
|
|
|
|
|
def __init__(self, desired_length, K, N, n):
|
|
|
|
|
self.desired_length = desired_length
|
|
|
|
|
self.rainbow_Cain = Rainbow_Cain(desired_length)
|
|
|
|
|
self.K = K
|
|
|
|
|
self.N = N
|
|
|
|
|
self.n = n
|
|
|
|
|
|
|
|
|
|
def generate_random_string(self, charset=(string.ascii_letters + string.digits)):
|
|
|
|
|
"""
|
|
|
|
|
生成指定位数的随机字符串
|
|
|
|
|
:param charset: 字符集（可选），默认为字母和数字
|
|
|
|
|
:return: 随机字符串
|
|
|
|
|
"""
|
|
|
|
|
return ''.join(random.choice(charset) for _ in range(self.desired_length))
|
|
|
|
|
|
|
|
|
|
def thread_cain(self):
|
|
|
|
|
"""
|
|
|
|
|
生成的数据为K*N条
|
|
|
|
|
:desired_length: 解密长度
|
|
|
|
|
:K: 轮数
|
|
|
|
|
:N: 轮次
|
|
|
|
|
"""
|
|
|
|
|
# 创建任务队列
|
|
|
|
|
task_queue = queue.Queue()
|
|
|
|
|
|
|
|
|
|
# 生成随机字符串列表
|
|
|
|
|
input_strings = [self.generate_random_string(charset=string.ascii_lowercase) for _ in range(self.N)]
|
|
|
|
|
|
|
|
|
|
# 将任务放入队列
|
|
|
|
|
for input_string in input_strings:
|
|
|
|
|
task_queue.put(input_string)
|
|
|
|
|
|
|
|
|
|
# 创建并启动线程
|
|
|
|
|
threads = []
|
|
|
|
|
for i in range(self.n): # 创建 n 个线程
|
|
|
|
|
thread = threading.Thread(target=self.worker, args=(task_queue,))
|
|
|
|
|
thread.start()
|
|
|
|
|
threads.append(thread)
|
|
|
|
|
|
|
|
|
|
# 等待所有任务完成
|
|
|
|
|
task_queue.join()
|
|
|
|
|
|
|
|
|
|
# 等待所有线程结束
|
|
|
|
|
for thread in threads:
|
|
|
|
|
thread.join()
|
|
|
|
|
|
|
|
|
|
print("所有任务已完成！")
|
|
|
|
|
|
|
|
|
|
def worker(self, task_queue):
|
|
|
|
|
# 每个线程创建独立的 Rainbow_Cain 实例
|
|
|
|
|
rainbow_Cain = Rainbow_Cain(self.desired_length)
|
|
|
|
|
while not task_queue.empty():
|
|
|
|
|
# 从队列中获取任务
|
|
|
|
|
input_string = task_queue.get()
|
|
|
|
|
# 执行任务
|
|
|
|
|
rainbow_Cain.Cain(input_string, self.K)
|
|
|
|
|
# 标记任务完成
|
|
|
|
|
task_queue.task_done()
|
