Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package main
- import (
- "log"
- "net"
- "net/rpc"
- "net/rpc/jsonrpc"
- )
- type Stat struct {
- }
- func (s *Stat) Put(args interface{}, reply *bool) error {
- log.Println(args)
- *reply = true
- return nil
- }
- func main() {
- stat := new(Stat)
- rpc := rpc.NewServer()
- rpc.Register(stat)
- l, err := net.Listen("tcp", ":7777")
- if err != nil {
- log.Fatal(err)
- }
- for {
- conn, err := l.Accept()
- if err != nil {
- log.Println(err)
- }
- go rpc.ServeCodec(jsonrpc.NewServerCodec(conn))
- }
- }
Add Comment
Please, Sign In to add comment