discox
支持类型
- zookeeper
- etcd
- consul
示例
zookeeper
server
package main
import (
"fmt"
"github.com/goeasya/discox"
"os"
)
func main() {
cfg := discox.RegisterConfig{
BackendType: discox.ZookeeperBackend,
BackendEndPoints: []string{"10.1.1.1:2181"},
DiscoverPrefix: "/soaservices",
ServiceName: "demo",
HeartBeatPeriod: 5,
ServiceEndPoint: "127.0.0.1:8111",
}
service, err := discox.NewRegister(&cfg)
if err != nil {
fmt.Println(err.Error())
os.Exit(1)
}
if err = service.Start(); err != nil {
fmt.Println(err.Error())
os.Exit(1)
}
defer service.Stop()
select {}
}
client
package main
import (
"fmt"
"github.com/goeasya/discox"
"os"
"time"
)
func main() {
timer := time.NewTimer(time.Second * 5)
cfg := discox.DiscoverConfig{
BackendEndPoints: []string{"10.1.1.1:2181"},
BackendType: discox.ZookeeperBackend,
DiscoverPrefix: "/soaservices",
ServiceName: "demo",
}
server, err := discox.NewDiscover(&cfg)
if err != nil {
fmt.Println(err.Error())
os.Exit(1)
}
endpointCacher := discox.NewLiteEndpoint()
go server.Start(endpointCacher)
defer server.Stop()
for {
select {
case <-timer.C:
fmt.Println("time 5 seconds")
endpoints := endpointCacher.List()
fmt.Println(endpoints, len(endpoints))
timer.Reset(time.Second * 5)
}
}
}
etcd
server
package main
import (
"fmt"
"os"
"github.com/goeasya/discox"
)
func main() {
cfg := discox.RegisterConfig{
BackendType: discox.EtcdBackend,
BackendEndPoints: []string{"http://10.1.1.1:23790"},
DiscoverPrefix: "/discox/etcddemo",
ServiceName: "demo",
HeartBeatPeriod: 5,
ServiceEndPoint: "127.0.0.1:8111",
}
service, err := discox.NewRegister(&cfg)
if err != nil {
fmt.Println(err.Error())
os.Exit(1)
}
if err = service.Start(); err != nil {
fmt.Println(err.Error())
os.Exit(1)
}
defer service.Stop()
select {}
}
client
package main
import (
"fmt"
"os"
"time"
"github.com/goeasya/discox"
)
func main() {
timer := time.NewTimer(time.Second * 5)
cfg := discox.DiscoverConfig{
BackendEndPoints: []string{"http://10.1.1.1:23790"},
BackendType: discox.EtcdBackend,
DiscoverPrefix: "/discox/etcddemo",
ServiceName: "demo",
}
server, err := discox.NewDiscover(&cfg)
if err != nil {
fmt.Println(err.Error())
os.Exit(1)
}
endpointCacher := discox.NewLiteEndpoint()
go server.Start(endpointCacher)
defer server.Stop()
for {
select {
case <-timer.C:
fmt.Println("time 5 seconds")
endpoints := endpointCacher.List()
fmt.Println(endpoints, len(endpoints))
timer.Reset(time.Second * 5)
}
}
}
consul
server
package main
import (
"fmt"
"net/http"
"os"
"github.com/goeasya/discox"
)
func main() {
cfg := discox.RegisterConfig{
BackendType: discox.ConsulBackend,
BackendEndPoints: []string{"consul.test.com"},
DiscoverPrefix: "/soaservices",
ServiceName: "demo",
HeartBeatPeriod: 5,
ServiceEndPoint: "172.18.1.1:8080",
HealthCheckEndPoint: "172.18.1.1:8080/check",
}
service, err := discox.NewRegister(&cfg)
if err != nil {
fmt.Println(err.Error())
os.Exit(1)
}
if err = service.Start(); err != nil {
fmt.Println(err.Error())
os.Exit(1)
}
http.HandleFunc("/check", consulCheck)
go http.ListenAndServe(":8080", nil)
defer service.Stop()
select {}
}
var count int64
func consulCheck(w http.ResponseWriter, r *http.Request) {
s := "consulCheck" + fmt.Sprint(count) + "remote:" + r.RemoteAddr + " " + r.URL.String()
fmt.Println(s)
fmt.Fprintln(w, s)
count++
}
client
package main
import (
"fmt"
"os"
"time"
"github.com/goeasya/discox"
)
func main() {
timer := time.NewTimer(time.Second * 5)
cfg := discox.DiscoverConfig{
BackendEndPoints: []string{"consul.test.com"},
BackendType: discox.ConsulBackend,
DiscoverPrefix: "/soaservices",
ServiceName: "demo",
}
server, err := discox.NewDiscover(&cfg)
if err != nil {
fmt.Println(err.Error())
os.Exit(1)
}
endpointCacher := discox.NewLiteEndpoint()
go server.Start(endpointCacher)
defer server.Stop()
for {
select {
case <-timer.C:
fmt.Println("time 5 seconds")
endpoints := endpointCacher.List()
fmt.Println(endpoints, len(endpoints))
timer.Reset(time.Second * 5)
}
}
}
