Почему не отправляет данные из канала?

Question

[Владимир Грабко]

Привет. Я хочу данные из терминала сервера отправить всем подключёным клиентам. Но я чего то туплю

package main

import (
	"bufio"
	"io"
	"log"
	"net"
	"os"
	"strconv"
	"strings"
	"time"
)

const (
	Message       = "Pong"
	StopCharacter = "\r\n\r\n"
)

func SocketServer(port int) {
	listen, err := net.Listen("tcp4", ":"+strconv.Itoa(port))
	defer listen.Close()
	if err != nil {
		log.Fatalf("Прослушивание порта %d не удалось,\r\n\r\n %s", port, err)
		os.Exit(1)
	}
	log.Printf("Сервер слушает порт: %d", port)
	for {
		conn, err := listen.Accept()
		if err != nil {
			log.Fatalln(err)
			continue
		}
		go handler(conn)
	}
}
func handler(conn net.Conn) {
	defer conn.Close()
	var (
		buf = make([]byte, 1024)
		r   = bufio.NewReader(conn)
		w   = bufio.NewWriter(conn)
	)
ILOOP:
	for {
		n, err := r.Read(buf)
		data := string(buf[:n])
		switch err {
		case io.EOF:
			break ILOOP
		case nil:
			log.Println("Получил:", data)
			if isTransportOver(data) {
				break ILOOP
			}
		default:
			log.Fatalf("Ошибка при получении:%s", err)
			return
		}
	}
	//данные из канала
	msg := <-messages
	w.Write([]byte(msg))
	w.Flush()

}
func isTransportOver(data string) (over bool) {
	over = strings.HasSuffix(data, "\r\n\r\n")
	return
}
func main() {
	Command := make(chan string)

	SocketServer(3333)

	reader := bufio.NewReader(os.Stdin)
	fmt.Print("Enter text: ")
	text, _ := reader.ReadString('\n')
	messages <- text
}

При компиляции в консоль пишет

C:\gopath\src\bot>go run main.go
panic: runtime error: invalid memory address or nil pointer dereference
[signal 0xc0000005 code=0x1 addr=0x0 pc=0x401613]

goroutine 1 [running]:
panic(0x547760, 0x10818030)
        C:/Go/src/runtime/panic.go:481 +0x326
main.Client(0x10802360, 0xc, 0xd05)
        C:/gopath/src/bot/main.go:47 +0x483
main.main()
        C:/gopath/src/bot/main.go:41 +0x37
exit status 2

Всем спасибо

upd.
Ошибка в том что функция SocketServer в вечном цикле ждёт подключений, а значит код

reader := bufio.NewReader(os.Stdin)
	fmt.Print("Enter text: ")
	text, _ := reader.ReadString('\n')
	messages <- text 
<code>
не когда не выполнится. Как мне это исправить?

Comments

[Илья]

С тем кодом, который вы дали, всё нормально.

[Владимир Грабко]

FireGM: а чего не компилится тогда?

[Илья]

Не телепат.

[Владимир Грабко]

FireGM: а можете у себя попробовать скомпилить? Возможно у меня что-то с пк не так.

[Никита]

Приведённый вами код неполный и никак не может быть скомпилен. play.golang.org/p/j7zifi3AFn

[Владимир Грабко]

Никита: код полный. Ошибку накшел. Обновил вопрос но так и не понял как её исправить

[Илья]

Владимир Грабко: как же он может быть полным, если переменная messages берётся из воздуха?

[Илья]

А вообще, можно просто перенести тот код, который вы считаете ошибочным, поставив перед запуском сокета.

[Владимир Грабко]

FireGM: я уже нашел. Я вместо messages создал Command. Сейчас попробую

[Владимир Грабко]

FireGM: я сделал вот так

func main() {

	var port int = 3333
	listen, err := net.Listen("tcp4", ":"+strconv.Itoa(port))
	defer listen.Close()
	if err != nil {
		log.Fatalf("Прослушивание порта %d не удалось,\r\n\r\n %s", port, err)
		os.Exit(1)
	}

	go func() {

		log.Printf("Сервер слушает порт: %d", port)
		reader := bufio.NewReader(os.Stdin)
		fmt.Print("Enter text: ")
		text, _ := reader.ReadString('\n')
		log.Print(text)
	
	}()
	for {
		conn, err := listen.Accept()
		if err != nil {
			log.Fatalln(err)
			continue
		}
		go handler(conn)
	}
}

Теперь я могу ввести текст 1 раз после запуска. Но а мне же необходимо вводить n раз после запуска

[Илья]

Вынести в горутину, запустить перед сокетом с for

[Владимир Грабко]

FireGM: так я в рутине перед for и запустил вроде бы. или сам for тоже в рутину?

[Владимир Грабко]

FireGM: вот весь код pastebin.com/VE4mTDWF

[Александр Павлюк]

Владимир Грабко: вам нужно, чтобы введенный в консоли сервера текст отправлялся всем клиентам?

[Владимир Грабко]

Александр Павлюк: даа

Answer 1

[Илья]

Понятия не имею как у вас создаётся канал messages, поэтому сделал обычный.

package main

import (
	"bufio"
	"fmt"
	"io"
	"log"
	"net"
	"os"
	"strconv"
	"strings"
)

var messages chan string

func main() {
	messages = make(chan string, 10)
	var port int = 3333
	listen, err := net.Listen("tcp4", ":"+strconv.Itoa(port))
	defer listen.Close()
	if err != nil {
		log.Fatalf("Прослушивание порта %d не удалось,\r\n\r\n %s", port, err)
		os.Exit(1)
	}

	go func() {

		log.Printf("Сервер слушает порт: %d", port)
		reader := bufio.NewReader(os.Stdin)
		for {
			fmt.Print("Enter text: ")
			text, _ := reader.ReadString('\n')
			log.Print(text)
			messages <- text
		}

	}()
	for {
		conn, err := listen.Accept()
		if err != nil {
			log.Fatalln(err)
			continue
		}
		go handler(conn)
	}
}
func handler(conn net.Conn) {
	defer conn.Close()
	var (
		buf = make([]byte, 1024)
		r   = bufio.NewReader(conn)
		w   = bufio.NewWriter(conn)
	)
ILOOP:
	for {
		n, err := r.Read(buf)
		data := string(buf[:n])
		switch err {
		case io.EOF:
			break ILOOP
		case nil:
			log.Println("Получил:", data)
			if isTransportOver(data) {
				break ILOOP
			}
		default:
			log.Fatalf("Ошибка при получении:%s", err)
			return
		}
	}
	//данные из канала
	msg := <-messages
	w.Write([]byte(msg))
	w.Flush()

}
func isTransportOver(data string) (over bool) {
	over = strings.HasSuffix(data, "\r\n\r\n")
	return
}

Comments

[Владимир Грабко]

оказалось что я не правильно создавал канал :(

[Владимир Грабко]

код это отправляет сообщение не всем а кому то одному

[Илья]

Владимир Грабко: потому что надо делать пул конектов? Мы что тут, работаем на вас? Идите читайте документацию, про архитектуру и научитесь пользоваться гуглом.