goyar

yar rpc library with json code in golang

Yar http server Example

package main

import (
	"fmt"
	"github.com/neverlee/goyar"
	"net/http"
)

type Arith int

func (t *Arith) Echo(i *int, r *int) error {
	*r = *i
	return nil
}

func main() {
	yar := goyar.NewYarServer()
	ar := new(Arith)
	yar.Register(ar)
	yar.HandleHTTP("/api.php")

	http.ListenAndServe(":8000", nil)
}

Same as php code

<?php
class Operator {
    public function Echo($a) {
        return $a;
    }
}
$server = new Yar_Server(new Operator());
$server->handle();

Yar http client Example

import (
    "fmt"
    "github.com/neverlee/goyar"
)

func main() {
    client := goyar.NewYHClient("http://yarserver/api.php", nil)
    var r int
    var err error
    err = client.MCall("add", &r, 3, 4)
    err = client.Call("Echo", 100, &r)
}

Same as php code

<?php
$client = new yar_client("http://yarserver/api.php");
$client->SetOpt(YAR_OPT_PACKAGER, "json"); #this is necessary.
$client->add(3, 4);
$client->Echo(1100);
?>

Yar tcp server Example

package main

import (
	"fmt"
	"github.com/neverlee/goyar"
	"net"
	"os"
)

type Arith int

func (t *Arith) Echo(i *int, r *int) error {
	*r = *i
	fmt.Println("do echo", *i)
	return nil
}

func main() {
	arith := new(Arith)

	yar := goyar.NewYarServer()
	yar.Register(arith)

	tcpAddr, err := net.ResolveTCPAddr("tcp", ":1234")
	checkError(err)

	listener, err := net.ListenTCP("tcp", tcpAddr)
	checkError(err)

	for {
		conn, err := listener.Accept()
		if err != nil {
			continue
		}
		yar.ServeConn(conn)
	}
}

func checkError(err error) {
	if err != nil {
		fmt.Println("Fatal error ", err.Error())
		os.Exit(1)
	}
}

Yar tcp client Example

package main

import (
	"fmt"
	"github.com/neverlee/goyar"
	"log"
)

type Args struct {
	A, B int
}

type Quotient struct {
	Quo, Rem int
}

func main() {
	client, err := goyar.Dial("tcp", "127.0.0.1:1234")
	if err != nil {
		log.Fatal("dialing:", err)
	}

	var r int
	fmt.Println(client.Call("Echo", 15, &r))
	fmt.Println(r)
}

LICENSE

Apache License