123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100 |
- package main
- import (
- "bufio"
- "encoding/json"
- "flag"
- "fmt"
- "log"
- "net"
- "os"
- "github.com/campoy/whispering-gophers/util"
- )
- var (
- peerAddr = flag.String("peer", "", "peer host:port")
- self string
- )
- type Message struct {
- Addr string
- Body string
- }
- func main() {
- flag.Parse()
-
-
-
- go dial(*peerAddr)
- for {
- c, err := l.Accept()
- if err != nil {
- log.Fatal(err)
- }
- go serve(c)
- }
- }
- func serve(c net.Conn) {
- defer c.Close()
- d := json.NewDecoder(c)
- for {
- var m Message
- err := d.Decode(&m)
- if err != nil {
- log.Println(err)
- return
- }
- fmt.Printf("%#v\n", m)
- }
- }
- func dial(addr string) {
- c, err := net.Dial("tcp", addr)
- if err != nil {
- log.Fatal(err)
- }
- s := bufio.NewScanner(os.Stdin)
- e := json.NewEncoder(c)
- for s.Scan() {
- m := Message{
-
- Body: s.Text(),
- }
- err := e.Encode(m)
- if err != nil {
- log.Fatal(err)
- }
- }
- if err := s.Err(); err != nil {
- log.Fatal(err)
- }
- }
|