| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374 |
- // Try net/rpc/jsonrpc between backend and frontend (via GopherJS) through a websocket connection.
- //
- // based on https://github.com/shurcooL/play/tree/master/42
- package main
- import (
- "fmt"
- "io"
- "net/http"
- "net/rpc"
- "net/rpc/jsonrpc"
- "github.com/shurcooL/go/gopherjs_http"
- "golang.org/x/net/websocket"
- )
- type Args struct {
- A, B int
- }
- type Arith struct {
- req *http.Request
- connClose func() error
- callCounter int
- }
- func (a *Arith) Multiply(args *Args, reply *int) error {
- fmt.Println(a.callCounter, "from", a.req.RemoteAddr)
- c, err := a.req.Cookie("JSESSIONID")
- if err != nil {
- return err
- }
- fmt.Println("cookie:", c)
- if a.callCounter > 5 {
- return a.connClose()
- }
- a.callCounter++
- *reply = args.A * args.B
- fmt.Printf("locally multiplying %v by %v -> %v\n", args.A, args.B, *reply)
- return nil
- }
- func main() {
- http.Handle("/rpc-websocket", websocket.Handler(func(conn *websocket.Conn) {
- s := rpc.NewServer()
- a := &Arith{
- req: conn.Request(),
- connClose: conn.Close,
- }
- s.Register(a)
- s.ServeCodec(jsonrpc.NewServerCodec(conn))
- }))
- http.HandleFunc("/index.html", func(w http.ResponseWriter, req *http.Request) {
- w.Header().Set("Content-Type", "text/html; charset=utf-8")
- io.WriteString(w, `<html>
- <head></head>
- <body>
- <pre id="output"></pre>
- <script type="text/javascript" src="/script.js"></script>
- </body>
- </html>
- `)
- })
- http.Handle("/script.js", gopherjs_http.GoFiles("./script.go"))
- err := http.ListenAndServe(":8880", nil)
- if err != nil {
- panic(err)
- }
- }
|
