Асинхронных сообщений golang

Question

У меня есть сервер golang делать что-то вроде этого: пакета главного

func main() { 
    for { 
     c := listener.Accept() 
     go handle(c) 
    } 
} 

... 
func handle(c net.Conn) { 
    m := readMessage(c) // func(net.Conn)Message 
    r := processMessage(m) //func(Message)Result 
    sendResult(c, r)  // func(net.Conn,Result) 
} 

, который считывает и записывает сообщения синхронно. Теперь мне нужно послать сообщения асинхронно через данное открытое соединение, я знаю, что канал может использоваться, я как бы потерял.

Это моя идея:

... 
func someWhereElese(c chan Result) { 
    // generate a message and a result 
    r := createResultFromSomewhere() 
    c <- r // send the result through the channel 
} 

И изменить мою ручку, чтобы использовать тот же канал вместо

func handle(c net.Conn, rc chan Result) { 
    m := readMessage(c) // func(net.Conn)Message 
    r := processMessage(m) //func(Message)Result 
    //sendResult(c, r)  // func(net.Conn,Result) 
    rc <- r 
} 

А вот где моя путаница лежит.

В результате канал должен быть создан, и он должен иметь соединение, куда послать то, что он получает

func doSend(c net.Con, rc chan Result) { 
    r := rc   // got a result channel 
    sendResult(c, r) // send it through the wire 
} 

Но где должен быть создан этот канал? В основном цикле?

func main() { 
    ... 
    for { 
     c := l.Accept() 
     rc := make(chan Result) 
     go doSend(c, rc) 
    } 
} 

А как насчет прочитанного? Должен ли он пойти в собственный канал/горутин? Если мне нужно транслировать до n клиентов, должен ли я хранить кусок результирующих каналов? кусок соединений?

Я здесь немного смущен, но я чувствую, что я рядом.

Answer 1

Эта программа, кажется, решить мой непосредственный вопрос

package main 

import (
    "bytes" 
    "encoding/binary" 
    "log" 

    "net" 
) 

var rcs []chan int = make([]chan int,0) 


func main() { 
    a, e := net.ResolveTCPAddr("tcp", ":8082") 
    if e != nil { 
     log.Fatal(e) 
    } 
    l, e := net.ListenTCP("tcp", a) 
    for { 
     c, e := l.Accept() 
     if e != nil { 
      log.Fatal(e) 
     } 
     rc := make(chan int) 
     go read(c, rc) 
     go write(c, rc) 
     rcs = append(rcs, rc) 
     // simulate broacast 
     log.Println(len(rcs)) 
     if len(rcs) > 5 { 
      func() { 
       for _, v := range rcs { 
        log.Println("sending") 
        select { 
        case v <- 34: 
         log.Println("done sending") 
        default: 
         log.Println("didn't send") 
        } 
       } 
      }() 
     } 
    } 
} 
func read(c net.Conn, rc chan int) { 
    h := make([]byte, 2) 
    for { 
     _, err := c.Read(h) 
     if err != nil { 
      rc <- -1 
     } 
     var v int16 
     binary.Read(bytes.NewReader(h[:2]), binary.BigEndian, &v) 
     rc <- int(v) 
    } 
} 
func write(c net.Conn, rc chan int) { 
    for { 
     r := <-rc 
     o := []byte{byte(r * 2)} 
     c.Write(o) 
    } 
}