123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354 |
- package main
- import (
- "bufio"
- "encoding/json"
- "flag"
- "log"
- "net"
- "os"
- )
- var dialAddr = flag.String("dial", "localhost:8000", "host:port to dial")
- type Message struct {
- Body string
- }
- func main() {
- flag.Parse()
- c, err := net.Dial("tcp4", *dialAddr)
- 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)
- }
- }
|