Skip to content

Instantly share code, notes, and snippets.

@jordanorelli
Created May 7, 2012 17:16
Show Gist options
  • Star 56 You must be signed in to star a gist
  • Fork 11 You must be signed in to fork a gist
  • Save jordanorelli/2629049 to your computer and use it in GitHub Desktop.
Save jordanorelli/2629049 to your computer and use it in GitHub Desktop.
rpc server example in go
package main
import (
"bufio"
"log"
"net/rpc"
"os"
)
func main() {
client, err := rpc.Dial("tcp", "localhost:42586")
if err != nil {
log.Fatal(err)
}
in := bufio.NewReader(os.Stdin)
for {
line, _, err := in.ReadLine()
if err != nil {
log.Fatal(err)
}
var reply bool
err = client.Call("Listener.GetLine", line, &reply)
if err != nil {
log.Fatal(err)
}
}
}
package main
import (
"fmt"
"log"
"net"
"net/rpc"
)
type Listener int
func (l *Listener) GetLine(line []byte, ack *bool) error {
fmt.Println(string(line))
return nil
}
func main() {
addy, err := net.ResolveTCPAddr("tcp", "0.0.0.0:42586")
if err != nil {
log.Fatal(err)
}
inbound, err := net.ListenTCP("tcp", addy)
if err != nil {
log.Fatal(err)
}
listener := new(Listener)
rpc.Register(listener)
rpc.Accept(inbound)
}
@KumarL
Copy link

KumarL commented Dec 17, 2014

Thanks for a simple, yet effective, example of rpc!

@kratorado
Copy link

Very helpful, thanx

@danielrangelmoreira
Copy link

Thanks

@alexniver
Copy link

thanks alot

@xgz123
Copy link

xgz123 commented May 30, 2018

very helpful

@wcc19940308
Copy link

thx

@Helshr
Copy link

Helshr commented Aug 4, 2021

Very helpful, thanx

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment