Почему сервер на Docker не справляется с aiohttp запросами?

kkolorid, "пачка ответов" приходит потому что используешь функцию gather, которая ожидает пока все корутины выполнятся и возвращает список результатов.

Как реализовать асинхронную обработку массива http запросов (asyncio / aiohttp)?

Что касается заголовков смотри здесь: https://aiohttp.readthedocs.io/en/stable/client_ad...

Пример из документации с заголовками и выводом "кроме await response.text()":

import asyncio

import aiohttp


async def fetch(url, session):
    async with session.get(url) as resp:
        json_body = await resp.json()
        print(json_body)


async def main():
    url = "http://httpbin.org/headers"
    headers = {"Authorization": "Basic bG9naW46cGFzcw=="}
    async with aiohttp.ClientSession(headers=headers) as session:
        await asyncio.create_task(fetch(url, session))


if __name__ == '__main__':
    asyncio.run(main())

Почему не подключается удаленный клиент к простому серверу на golang запущенному локально?

А на удаленном выделенном какой IP адрес?

Что делает скрипт в Python?

Берешь код, идешь на www.pythontutor.com/visualize.html#mode=edit, вставляешь код в поле для кода, нажимаешь кнопку "Visualize Execution". Дальше пошагово можешь посмотреть как работает код.

Обмен сокетов между Python и Java?

Spider20, пожалуйста.

Как реализовать интерфейс, в котором можно регистрировать функции на подобии http.HandleFunc?

Алексей, еще раз смотрим в пакет "net/http":

var DefaultServeMux = &defaultServeMux

var defaultServeMux ServeMux

...

type ServeMux struct {
	mu    sync.RWMutex
	m     map[string]muxEntry
	hosts bool // whether any patterns contain hostnames
}

type muxEntry struct {
	h       Handler
	pattern string
}

func HandleFunc(pattern string, handler func(ResponseWriter, *Request)) {
  DefaultServeMux.HandleFunc(pattern, handler)
}

func (mux *ServeMux) HandleFunc(pattern string, handler func(ResponseWriter, *Request)) {
  if handler == nil {
    panic("http: nil handler")
  }
  mux.Handle(pattern, HandlerFunc(handler))
}

func (mux *ServeMux) Handle(pattern string, handler Handler) {
  mux.mu.Lock()
  defer mux.mu.Unlock()

  if pattern == "" {
    panic("http: invalid pattern")
  }
  if handler == nil {
    panic("http: nil handler")
  }
  if _, exist := mux.m[pattern]; exist {
    panic("http: multiple registrations for " + pattern)
  }

  if mux.m == nil {
    mux.m = make(map[string]muxEntry)
  }
  mux.m[pattern] = muxEntry{h: handler, pattern: pattern}

  if pattern[0] != '/' {
    mux.hosts = true
  }
}

В методе Handle есть такой кусок кода:

...
  if mux.m == nil {
    mux.m = make(map[string]muxEntry)
  }
...

Как реализовать интерфейс, в котором можно регистрировать функции на подобии http.HandleFunc?

Алексей, в пакете "net/http" уже объявлена переменная DefaultServeMux тип ServeMux:

// код из пакета net/http
var DefaultServeMux = &defaultServeMux
var defaultServeMux ServeMux

которая имеет вид:

// код из пакета net/http
type ServeMux struct {
  mu    sync.RWMutex
  m     map[string]muxEntry
  hosts bool // whether any patterns contain hostnames
}

type muxEntry struct {
  h       Handler
  pattern string
}

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

Как реализовать интерфейс, в котором можно регистрировать функции на подобии http.HandleFunc?

Bekkazy, у структуры ServeMux( есть поле map[string]muxEntry, где хранятся хэндлеры) По умолчанию все хэндлеры попадают в DefaultServeMux, в пакете "net/http" уже все определено:

// код из пакета net/http
var DefaultServeMux = &defaultServeMux
var defaultServeMux ServeMux

А по твоему где хранятся обработчики когда ты используешь "net/http"? По умолчанию они хранятся в DefaultServeMux. В моем примере роль DefaultServeMux исполняет HandlersMap.

Как реализовать интерфейс, в котором можно регистрировать функции на подобии http.HandleFunc?

Bekkazy, мне до сих пор не понятна фраза:

... регистрировать хэндлеры вне пакета, чтобы они потом вызывались?

Как реализовать интерфейс, в котором можно регистрировать функции на подобии http.HandleFunc?

Bekkazy, если посмотреть в пакет http там объявляется DefaultServeMux который представляет из себя следующую структуру:

var DefaultServeMux = &defaultServeMux

var defaultServeMux ServeMux

type ServeMux struct {
	mu    sync.RWMutex
	m     map[string]muxEntry
	hosts bool // whether any patterns contain hostnames
}

type muxEntry struct {
	h       Handler
	pattern string
}

func HandleFunc(pattern string, handler func(ResponseWriter, *Request)) {
	DefaultServeMux.HandleFunc(pattern, handler)
}

func (mux *ServeMux) HandleFunc(pattern string, handler func(ResponseWriter, *Request)) {
	if handler == nil {
		panic("http: nil handler")
	}
	mux.Handle(pattern, HandlerFunc(handler))
}

func (mux *ServeMux) Handle(pattern string, handler Handler) {
	mux.mu.Lock()
	defer mux.mu.Unlock()

	if pattern == "" {
		panic("http: invalid pattern")
	}
	if handler == nil {
		panic("http: nil handler")
	}
	if _, exist := mux.m[pattern]; exist {
		panic("http: multiple registrations for " + pattern)
	}

	if mux.m == nil {
		mux.m = make(map[string]muxEntry)
	}
	mux.m[pattern] = muxEntry{h: handler, pattern: pattern}

	if pattern[0] != '/' {
		mux.hosts = true
	}
}

Как считать данные с tcp запроса метода net.Listen?

Bekkazy, Я все свои примеры проверял. Все передается без ошибок, брал вывод однострочного файла и отправлял содержимое в соединение, сервер все получает. Посылал вывод многострочного файла, тоже никаких проблем с получением на сервере. В качестве клиента использовал netcat.

Как считать данные с tcp запроса метода net.Listen?

Bekkazy, первое, что пришло в голову:

func handler(conn net.Conn) {
	buf := make([]byte, 1024)
	b := bufio.NewReader(conn)
	for {
		line, err := b.ReadBytes('\n')
		if err != nil { // for example EOF
			break
		}
		buf = append(buf, line...)
	}
	fmt.Print(string(buf))
}

Когда не видишь весь код как то проблематично делать какие то заключения. + Вопрос, каким образом отправляются "запросы", что это за "запросы"?

Как корректно закрывать tcp соединение?

rustler2000, видимо ошибок никаких нет и цикл крутит бесконечно.

Как корректно закрывать tcp соединение?

Алексей Маслов, если крутится бесконечно, то с чего ты взял что отработает
defer conn.Close()
?

Превышен лимит файловых дескрипторов т.к. соединения не закрываются. Видишь логику?

Как корректно закрывать tcp соединение?

Алексей Маслов, с чего ты взял что?

соединение явно закрывается: conn.Close()

Может я чего-то не понимаю, но я не увидел условия выхода из самого первого цикла:

for {
        conn, err := net.Dial("tcp", "адрес сервера")
        ...
        defer conn.Close()

Как корректно закрывать tcp соединение?

go dial error on addr dial tcp socket: to many open files

Данная ошибка говорит о том, что превышен лимит максимального кол-ва открытых файловых дискрипторов.
Данный лимит можно посмотреть командой:
ulimit -n

Как считать данные с tcp запроса метода net.Listen?

Bekkazy,

func handleRequest(conn net.Conn) {
	b := bufio.NewReader(conn)
	for {
		line, err := b.ReadBytes('\n')
		if err != nil { // for example EOF
			break
		}
		fmt.Print(string(line))
		conn.Write(line)
	}
}

Как считать данные с tcp запроса метода net.Listen?

Bekkazy, для начала, попробуй так:

func handleRequest(conn net.Conn) {
	message, _ := bufio.NewReader(conn).ReadString('\n')
	fmt.Print("Message received:", string(message))
	conn.Write([]byte("Message received."))
	conn.Close()
}

Как понять, какой тип у требуемого объекта в аргументе?

JackShcherbakov, flask.pocoo.org/docs/1.0/api/?highlight=request#fl...

Как правильно выполнить http.NewRequest с кириллицей?

Pavel Tananykhin, отредактировал свой ответ.