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

Question

[Алексей Маслов]

Есть некий сервис, написанный на Go, запущенный на Ubuntu 16.04.
Суть работы в том, что он опрашивает порядка 30 серверов.
После получения данных от сервера - должен в ответ послать информацию, что данные получены, в ответ на это сервер кинет еще порцию данных и так далее. Бывает так, что данные на сервере кончились, и тогда просто засыпаю на 60 секунд, затем все по-новой.
Так же бывает, что сервера не отвечают (обрыв сети или еще какие то проблема на стороне сервера (не важно)), в таких случаях закрываю соединение и пытаюсь подключиться по-новой, через определенный интервал.
Дак вот после запуска сервиса - наблюдаю следующую картину:


Затем, через какое то время (видимо когда произошли дисконнекты):


Что в последствии (часов через 6) приводит к ошибке: go dial error on addr dial tcp socket: to many open files
т.е. создается socket? B соединение как бы остается в подвисшем состоянии?
Хотя соединение явно закрывается: conn.Close()

примерный код, чтобы понимать, что к чему:

//Сбор данных - вызов в гоурутине
func stantionListener(server Servers, p DataProducer)  {
	//Основной цикл для сервера
	for {
		conn, err := net.Dial("tcp", "адрес сервера")
		if err != nil {
			log.Fatal("dial error on addr:", addr, err)
			return
		}
		defer conn.Close()
		
		//Цикл, в котором происходит обмен с сервером данными
		for {
			if wr, err := conn.Write([]byte("Запрос к серверу")); //Запрос #1
				wr == 0 || err != nil {
				log.Println(addr, err)
				break
			}
			err = conn.SetReadDeadline(time.Now().Add(5 * time.Second))
			if err != nil {
				log.Println(addr, err)
				break
			}

			//Пытаемся получить данные в ответ
			buff := make([]byte, 1024)
			rd, err := conn.Read(buff)
			if err != nil{
				log.Println(addr, err)
			}

			err = res.Parser(buff[:rd])
			if err != nil {
				log.Println(err, stDesc)
			} else {
				//Отправляем запрос о том, что все ок
				if wr, err := conn.Write([]byte("ok, данные получил")); //Запрос #4
					wr == 0 || err != nil {
					log.Println(err, stDesc)
				}
			}

			d := time.Duration(kpi.current * float32(time.Second))
			time.Sleep(d)
		}//end for

		log.Println("error, when connect or receive data", stDesc, "wait 60seconds")
		time.Sleep(time.Minute) //Ждем 1 минуту, прежде чем выполнить повторное подключение
	}
}

Как я понял, при повторном подключении к тому же серверу создается вместо TYPE: IPv4 - sock, device: 0x7

Comments

[igorzakhar]

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

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

[Алексей Маслов]

igorzakhar, Спасибо за ответ, но это я уже гуглил. Суть вопроса в том, почему создаются и остаются висеть sock, device: 0x7 при закрытии подключения?

[igorzakhar]

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

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

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

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

[Алексей Маслов]

igorzakhar, смысл в том, что в первом цикле крутится бесконечно, и выходить из него не нужно.

А defer conn.Close() по ходу сработает, при выходе из первого цикла?

[igorzakhar]

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

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

[Алексей Маслов]

igorzakhar, я облажался.

Большое спасибо!

[rustler2000]

igorzakhar, там break по ошибке

[igorzakhar]

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

Answer 1

[igorzakhar]

Не отрабатывает вызов:
defer conn.Close()
из-за бесконечного цикла.

Answer 2

[vipsiteedit]

Закрывай соединение в конце первого цикла conn.Close(), так как defer выполняется только при завершении метода.

.....
      d := time.Duration(kpi.current * float32(time.Second))
      time.Sleep(d)
    }//end for
    conn.Close()
    log.Println("error, when connect or receive data", stDesc, "wait 60seconds")
    time.Sleep(time.Minute) //Ждем 1 минуту, прежде чем выполнить повторное подключение
  }
}

Или сделать отдельный метод внутри первого цикла, в котором можно использовать defer conn.Close()