Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package main
- import (
- "bufio"
- "fmt"
- "net"
- )
- type Message struct {
- body string
- id int
- }
- func (m Message) Body() string {
- return m.body
- }
- func (m Message) Id() int {
- return m.id
- }
- func client(msg chan Message, conn net.Conn) error {
- fmt.Print("clinet")
- for {
- m, err := bufio.NewReader(conn).ReadString('\n')
- if err != nil {
- break
- }
- msg <- Message{ m, 0 }
- }
- conn.Close()
- return nil
- }
- func acceptor(msg chan Message) {
- ln, _ := net.Listen("tcp", ":2020")
- for {
- conn, err := ln.Accept()
- if err != nil {
- continue
- }
- go client(msg, conn)
- }
- }
- func msg(msg chan Message) {
- for m := range msg {
- fmt.Print(m.Body())
- }
- }
- func main() {
- msg := make(chan Message, 10)
- acceptor(msg)
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement