Port Forwaring

@Dark Deed · Регистрация: 22.05.2017

Студворк — интернет-сервис помощи студентам

У меня вот такой вот вопрос. Есть программа, что должна считывать динамически изменяемый файл, и собирать данные веса и связанный с ним ip address. Далее эта программа слушает весь траффик с 80 порта, и перенаправляет его на один из серверов в кластере, чей ip указан в файле. При этом сервер выбирается на основе веса.

Программа успешно считывает файл, открывает сокеты, принимает соединения, но не перенаправляет данные. Ниже пример программы, что я делаю не так?

Проблема в этой части: def forward(source, destination):

Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
import socket
import sys
import threading
import time
import math
import functools
from operator import itemgetter
 
settings = list()
weight_list = list()
minus_list = list()
 
def __getitem__(self, row):
    return self.data[row]
 
def gcd(L):
    return functools.reduce(math.gcd, L)
 
def main(setup, error):
    sys.stderr = open(error, 'a')
 
    for line in open(setup):
        parts = line.split()
        weight_list.append([int(parts[0]), parts[1], int(parts[2]), int(parts[3]), int(parts[4]), int(parts[5])])
    settings = list(weight_list)
    for i in range(len(settings)):
        minus_list.append(settings[i][5])
    minus = gcd(minus_list)
    settings.sort(key=itemgetter(5), reverse=True)
    setting = tuple(settings[0])
    settings[0][5] = settings[0][5]-minus
    threading.Thread(target=server, args=(settings, setup, minus, setting)).start()
 
def server(settings, setup, minus, setting):
        try:
                dock_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                dock_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
                dock_socket.bind(('', 80))
                dock_socket.listen(5)
                while True:
                        client_socket = dock_socket.accept()
                        server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                        server_socket.connect((setting[1], 80))
                        threading.Thread(target=forward, args=(client_socket, server_socket)).start()
                        threading.Thread(target=forward, args=(server_socket, client_socket)).start()
        finally:
                if settings[0][5]<=0:
                        weight_list = list()
                        for line in open(setup):
                                parts = line.split()
                                weight_list.append([int(parts[0]), parts[1], int(parts[2]), int(parts[3]), int(parts[4]), int(parts[5])])
                        settings = weight_list
                        for i in range(len(settings)):
                                minus_list.append(settings[i][5])
                        minus = gcd(minus_list)
                settings.sort(key=itemgetter(5), reverse=True)
                setting = tuple(settings[0])
                settings[0][5] = settings[0][5]-minus
                threading.Thread(target=server, args=(settings, setup, minus, setting)).start()
 
def forward(source, destination):
        string = ''
        print('work')
        while string:
                string = source.recv(4096)
                if string:
                        destination.sendall(string)
                else:
                        source.shutdown(socket.SHUT_RD)
                        destination.shutdown(socket.SHUT_WR)
 
if __name__ == '__main__':
        main('round-robin.conf', 'error.log')

Рыжий Лис · 25.05.2017, 16:23

Python
1
2
3
4
5
6
7
def forward(socket_source, socket_destination):
    while True:
        data = socket_source.recv(4096)
        if data:
            socket_destination.sendall(data)
    # socket_source.shutdown(socket.SHUT_RD)
    # socket_destination.shutdown(socket.SHUT_WR)

@Dark Deed · 26.05.2017, 07:37 **[ТС]**

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

@Slice_ · 28.05.2017, 23:13

если я правильно понял, и все дело в перенаправлении данных, то

Python
1
2
3
4
while True:
    data,addr = socket_source.recvfrom(4096)
    if data and addr:
        socket_destination.sendto(data,addr)

или recvfrom только с UDP работает ?

@Dark Deed · 29.05.2017, 01:16 **[ТС]**

socket.sendto: Send data to the socket. The socket should not be connected to a remote socket, since the destination socket is specified by address.

Иными словами, он заменяет server_socket.connect((setting[1], 80))
Но это одноразовая передача, которая будет создавать соединение при каждом проходе цикла, а нужно на одном соединении несколько передач, пока не закроется.

Новые блоги и статьи Все статьи Все блоги /
Изучаю kubernetes lagorue 13.01.2026 А пригодятся-ли мне знания kubernetes в России?	Сукцессия микоризы: основная теория в виде двух уравнений. anaschu 11.01.2026 https:/ / rutube. ru/ video/ 7a537f578d808e67a3c6fd818a44a5c4/	WordPad для Windows 11 Jel 10.01.2026 WordPad для Windows 11 — это приложение, которое восстанавливает классический текстовый редактор WordPad в операционной системе Windows 11. После того как Microsoft исключила WordPad из. . .	Classic Notepad for Windows 11 Jel 10.01.2026 Old Classic Notepad for Windows 11 Приложение для Windows 11, позволяющее пользователям вернуть классическую версию текстового редактора «Блокнот» из Windows 10. Программа предоставляет более. . .
Почему дизайн решает? Neotwalker 09.01.2026 В современном мире, где конкуренция за внимание потребителя достигла пика, дизайн становится мощным инструментом для успеха бренда. Это не просто красивый внешний вид продукта или сайта — это. . .	Модель микоризы: классовый агентный подход 3 anaschu 06.01.2026 aa0a7f55b50dd51c5ec569d2d10c54f6/ O1rJuneU_ls https:/ / vkvideo. ru/ video-115721503_456239114	Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ФедосеевПавел 06.01.2026 Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ВВЕДЕНИЕ Введу сокращения: аналоговый ПИД — ПИД регулятор с управляющим выходом в виде числа в диапазоне от 0% до. . .	Модель микоризы: классовый агентный подход 2 anaschu 06.01.2026 репозиторий https:/ / github. com/ shumilovas/ fungi ветка по-частям. коммит Create переделка под биомассу. txt вход sc, но sm считается внутри мицелия. кстати, обьем тоже должен там считаться. . . .

@Dark Deed 0 / 0 / 0 Регистрация: 22.05.2017 Сообщений: 3
	26.05.2017, 07:37 [ТС]
	К сожалению с такими изменениями такой же результат. При попытке присоединиться браузером идёт загрузка страницы, и на ней останавливается. 0

@Dark Deed 0 / 0 / 0 Регистрация: 22.05.2017 Сообщений: 3
	29.05.2017, 01:16 [ТС]
	socket.sendto: Send data to the socket. The socket should not be connected to a remote socket, since the destination socket is specified by address. Иными словами, он заменяет server_socket.connect((setting[1], 80)) Но это одноразовая передача, которая будет создавать соединение при каждом проходе цикла, а нужно на одном соединении несколько передач, пока не закроется. 0