Finish test-nacos
This commit is contained in:
Liujian
@@ -2,9 +2,10 @@ package nacos
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"reflect"
|
||||
|
||||
"github.com/eolinker/eosc"
|
||||
"github.com/eolinker/goku-eosc/discovery"
|
||||
"reflect"
|
||||
)
|
||||
|
||||
const (
|
||||
@@ -31,7 +32,7 @@ func (d *driver) ConfigType() reflect.Type {
|
||||
func (d *driver) Create(id, name string, v interface{}, workers map[eosc.RequireId]interface{}) (eosc.IWorker, error) {
|
||||
cfg, ok := v.(*Config)
|
||||
if !ok {
|
||||
return nil, fmt.Errorf("need %s,now %s:%w", eosc.TypeNameOf((*Config)(nil)), eosc.TypeNameOf(v), eosc.ErrorStructType)
|
||||
return nil, fmt.Errorf("need %s,now %s", eosc.TypeNameOf((*Config)(nil)), eosc.TypeNameOf(v))
|
||||
}
|
||||
return &nacos{
|
||||
id: id,
|
||||
|
||||
@@ -4,13 +4,14 @@ import (
|
||||
"context"
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"github.com/eolinker/eosc"
|
||||
"github.com/eolinker/goku-eosc/discovery"
|
||||
"io/ioutil"
|
||||
"net/http"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/eolinker/eosc"
|
||||
"github.com/eolinker/goku-eosc/discovery"
|
||||
)
|
||||
|
||||
const (
|
||||
@@ -61,7 +62,7 @@ func (n *nacos) Start() error {
|
||||
if err != nil {
|
||||
continue
|
||||
}
|
||||
nodes := make([]discovery.INode, len(res))
|
||||
nodes := make([]discovery.INode, 0, len(res))
|
||||
for _, v := range res {
|
||||
nodes = append(nodes, v)
|
||||
}
|
||||
@@ -80,7 +81,7 @@ func (n *nacos) Start() error {
|
||||
func (n *nacos) Reset(conf interface{}, workers map[eosc.RequireId]interface{}) error {
|
||||
cfg, ok := conf.(*Config)
|
||||
if !ok {
|
||||
return fmt.Errorf("need %s,now %s:%w", eosc.TypeNameOf((*Config)(nil)), eosc.TypeNameOf(conf), eosc.ErrorStructType)
|
||||
return fmt.Errorf("need %s,now %s", eosc.TypeNameOf((*Config)(nil)), eosc.TypeNameOf(conf))
|
||||
}
|
||||
n.address = cfg.Config.Address
|
||||
n.params = cfg.Config.Params
|
||||
|
||||
81
upstream/upstream-http/upstream_consul_test.go
Normal file
81
upstream/upstream-http/upstream_consul_test.go
Normal file
@@ -0,0 +1,81 @@
|
||||
package upstream_http
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"strings"
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/eolinker/goku-eosc/discovery/consul"
|
||||
|
||||
round_robin "github.com/eolinker/goku-eosc/upstream/round-robin"
|
||||
|
||||
http_context "github.com/eolinker/goku-eosc/node/http-context"
|
||||
|
||||
"github.com/eolinker/goku-eosc/upstream"
|
||||
|
||||
"github.com/eolinker/eosc"
|
||||
)
|
||||
|
||||
func TestConsul(t *testing.T) {
|
||||
round_robin.Register()
|
||||
consulConfig := &Config{
|
||||
Name: "product-user",
|
||||
Driver: "http_proxy",
|
||||
Desc: "生产环境-用户模块",
|
||||
Scheme: "http",
|
||||
Type: "round-robin",
|
||||
Config: "consul",
|
||||
Discovery: "consul_1@discovery",
|
||||
}
|
||||
|
||||
consulWorker, err := getWorker(consul.NewFactory(), &consul.Config{
|
||||
Name: "consul_1",
|
||||
Driver: "consul",
|
||||
Labels: map[string]string{
|
||||
"scheme": "http",
|
||||
},
|
||||
Config: consul.AccessConfig{
|
||||
Address: []string{"39.108.94.48:8500", "39.108.94.48:8501"},
|
||||
Params: map[string]string{"token": "a92316d8-5c99-4fa0-b4cd-30b9e66718aa"},
|
||||
},
|
||||
}, "discovery", "consul", "", "consul", nil, "", "consul_1", nil)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
consulWorker.Start()
|
||||
allWorker := make(map[eosc.RequireId]interface{})
|
||||
allWorker["consul_1@discovery"] = consulWorker
|
||||
worker, err := getWorker(NewFactory(), consulConfig, "upstream", "http_proxy", "", "http转发驱动", nil, "", "product-user", allWorker)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
|
||||
hUpstream, ok := worker.(upstream.IUpstream)
|
||||
if !ok {
|
||||
t.Error(ErrorStructType)
|
||||
|
||||
}
|
||||
data := url.Values{}
|
||||
data.Set("name", "eolinker")
|
||||
r, err := http.NewRequest("POST", "http://localhost:8080/Web/Test/params/print", strings.NewReader(data.Encode()))
|
||||
if err != nil {
|
||||
t.Error(ErrorStructType)
|
||||
}
|
||||
|
||||
ctx := http_context.NewContext(r, &response{})
|
||||
// 设置目标URL
|
||||
ctx.ProxyRequest.SetTargetURL(r.URL.Path)
|
||||
for i := 0; i < 10; i++ {
|
||||
now := time.Now()
|
||||
err = send(ctx, s, hUpstream)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
fmt.Println("spend time is", time.Now().Sub(now))
|
||||
}
|
||||
}
|
||||
215
upstream/upstream-http/upstream_eureka_test.go
Normal file
215
upstream/upstream-http/upstream_eureka_test.go
Normal file
@@ -0,0 +1,215 @@
|
||||
package upstream_http
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"strings"
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/eolinker/goku-eosc/discovery/nacos"
|
||||
|
||||
"github.com/eolinker/goku-eosc/discovery/eureka"
|
||||
|
||||
round_robin "github.com/eolinker/goku-eosc/upstream/round-robin"
|
||||
|
||||
"github.com/eolinker/goku-eosc/discovery/static"
|
||||
|
||||
http_context "github.com/eolinker/goku-eosc/node/http-context"
|
||||
|
||||
"github.com/eolinker/goku-eosc/upstream"
|
||||
|
||||
"github.com/eolinker/eosc"
|
||||
)
|
||||
|
||||
func TestEureka(t *testing.T) {
|
||||
round_robin.Register()
|
||||
eurekaConfig := &Config{
|
||||
Name: "product-user",
|
||||
Driver: "http_proxy",
|
||||
Desc: "生产环境-用户模块",
|
||||
Scheme: "http",
|
||||
Type: "round-robin",
|
||||
Config: "DEMO",
|
||||
Discovery: "eureka_1@discovery",
|
||||
}
|
||||
|
||||
eurekaWorker, err := getWorker(eureka.NewFactory(), &eureka.Config{
|
||||
Name: "eureka_1",
|
||||
Driver: "eureka",
|
||||
Labels: map[string]string{
|
||||
"scheme": "http",
|
||||
},
|
||||
Config: eureka.AccessConfig{
|
||||
Address: []string{"39.108.94.48:8761/eureka"},
|
||||
Params: map[string]string{
|
||||
"username": "test",
|
||||
"password": "test"},
|
||||
},
|
||||
}, "discovery", "eureka", "", "eureka", nil, "", "eureka_1", nil)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
eurekaWorker.Start()
|
||||
allWorker := make(map[eosc.RequireId]interface{})
|
||||
allWorker["eureka_1@discovery"] = eurekaWorker
|
||||
worker, err := getWorker(NewFactory(), eurekaConfig, "upstream", "http_proxy", "", "http转发驱动", nil, "", "product-user", allWorker)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
|
||||
hUpstream, ok := worker.(upstream.IUpstream)
|
||||
if !ok {
|
||||
t.Error(ErrorStructType)
|
||||
|
||||
}
|
||||
data := url.Values{}
|
||||
data.Set("name", "eolinker")
|
||||
r, err := http.NewRequest("POST", "http://localhost:8080/Web/Test/params/print", strings.NewReader(data.Encode()))
|
||||
if err != nil {
|
||||
t.Error(ErrorStructType)
|
||||
}
|
||||
|
||||
ctx := http_context.NewContext(r, &response{})
|
||||
// 设置目标URL
|
||||
ctx.ProxyRequest.SetTargetURL(r.URL.Path)
|
||||
for i := 0; i < 10; i++ {
|
||||
now := time.Now()
|
||||
err = send(ctx, s, hUpstream)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
fmt.Println("spend time is", time.Now().Sub(now))
|
||||
}
|
||||
}
|
||||
|
||||
func TestNacos(t *testing.T) {
|
||||
round_robin.Register()
|
||||
nacosConfig := &Config{
|
||||
Name: "product-user",
|
||||
Driver: "http_proxy",
|
||||
Desc: "生产环境-用户模块",
|
||||
Scheme: "http",
|
||||
Type: "round-robin",
|
||||
Config: "nacos.naming.serviceName",
|
||||
Discovery: "nacos_1@discovery",
|
||||
}
|
||||
|
||||
nacosWorker, err := getWorker(nacos.NewFactory(), &nacos.Config{
|
||||
Name: "nacos_1",
|
||||
Driver: "nacos",
|
||||
Labels: map[string]string{
|
||||
"scheme": "http",
|
||||
},
|
||||
Config: nacos.AccessConfig{
|
||||
Address: []string{"39.108.94.48:8848"},
|
||||
Params: map[string]string{
|
||||
"username": "test",
|
||||
"password": "test",
|
||||
"healthOnly": "false",
|
||||
},
|
||||
},
|
||||
}, "discovery", "nacos", "", "nacos", nil, "", "nacos_1", nil)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
nacosWorker.Start()
|
||||
allWorker := make(map[eosc.RequireId]interface{})
|
||||
allWorker["nacos_1@discovery"] = nacosWorker
|
||||
worker, err := getWorker(NewFactory(), nacosConfig, "upstream", "http_proxy", "", "http转发驱动", nil, "", "product-user", allWorker)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
|
||||
hUpstream, ok := worker.(upstream.IUpstream)
|
||||
if !ok {
|
||||
t.Error(ErrorStructType)
|
||||
|
||||
}
|
||||
data := url.Values{}
|
||||
data.Set("name", "eolinker")
|
||||
r, err := http.NewRequest("POST", "http://localhost:8080/Web/Test/params/print", strings.NewReader(data.Encode()))
|
||||
if err != nil {
|
||||
t.Error(ErrorStructType)
|
||||
}
|
||||
|
||||
ctx := http_context.NewContext(r, &response{})
|
||||
// 设置目标URL
|
||||
ctx.ProxyRequest.SetTargetURL(r.URL.Path)
|
||||
for i := 0; i < 10; i++ {
|
||||
now := time.Now()
|
||||
err = send(ctx, s, hUpstream)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
fmt.Println("spend time is", time.Now().Sub(now))
|
||||
}
|
||||
}
|
||||
|
||||
func TestStatic(t *testing.T) {
|
||||
round_robin.Register()
|
||||
staticConfig := &Config{
|
||||
Name: "product-user",
|
||||
Driver: "http_proxy",
|
||||
Desc: "生产环境-用户模块",
|
||||
Scheme: "http",
|
||||
Type: "round-robin",
|
||||
Config: "127.0.0.1:8580 weight=10;47.95.203.198:8080 weight=20",
|
||||
Discovery: "static_1@discovery",
|
||||
}
|
||||
|
||||
staticWorker, err := getWorker(static.NewFactory(), &static.Config{
|
||||
Name: "static_1",
|
||||
Driver: "static",
|
||||
Labels: nil,
|
||||
Health: &static.HealthConfig{
|
||||
Protocol: "http",
|
||||
Method: "POST",
|
||||
URL: "/Web/Test/params/print",
|
||||
SuccessCode: 200,
|
||||
Period: 30,
|
||||
Timeout: 3000,
|
||||
},
|
||||
HealthOn: true,
|
||||
}, "discovery", "static", "", "静态服务发现", nil, "", "static_1", nil)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
allWorker := make(map[eosc.RequireId]interface{})
|
||||
allWorker["static_1@discovery"] = staticWorker
|
||||
worker, err := getWorker(NewFactory(), staticConfig, "upstream", "http_proxy", "", "http转发驱动", nil, "", "product-user", allWorker)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
|
||||
hUpstream, ok := worker.(upstream.IUpstream)
|
||||
if !ok {
|
||||
t.Error(ErrorStructType)
|
||||
|
||||
}
|
||||
data := url.Values{}
|
||||
data.Set("name", "eolinker")
|
||||
r, err := http.NewRequest("POST", "http://localhost:8080/Web/Test/params/print", strings.NewReader(data.Encode()))
|
||||
if err != nil {
|
||||
t.Error(ErrorStructType)
|
||||
}
|
||||
|
||||
ctx := http_context.NewContext(r, &response{})
|
||||
// 设置目标URL
|
||||
ctx.ProxyRequest.SetTargetURL(r.URL.Path)
|
||||
for i := 0; i < 10; i++ {
|
||||
now := time.Now()
|
||||
err = send(ctx, s, hUpstream)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
fmt.Println("spend time is", time.Now().Sub(now))
|
||||
}
|
||||
}
|
||||
85
upstream/upstream-http/upstream_nacos_test.go
Normal file
85
upstream/upstream-http/upstream_nacos_test.go
Normal file
@@ -0,0 +1,85 @@
|
||||
package upstream_http
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"strings"
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/eolinker/goku-eosc/discovery/nacos"
|
||||
|
||||
round_robin "github.com/eolinker/goku-eosc/upstream/round-robin"
|
||||
|
||||
http_context "github.com/eolinker/goku-eosc/node/http-context"
|
||||
|
||||
"github.com/eolinker/goku-eosc/upstream"
|
||||
|
||||
"github.com/eolinker/eosc"
|
||||
)
|
||||
|
||||
func TestNacos(t *testing.T) {
|
||||
round_robin.Register()
|
||||
nacosConfig := &Config{
|
||||
Name: "product-user",
|
||||
Driver: "http_proxy",
|
||||
Desc: "生产环境-用户模块",
|
||||
Scheme: "http",
|
||||
Type: "round-robin",
|
||||
Config: "nacos.naming.serviceName",
|
||||
Discovery: "nacos_1@discovery",
|
||||
}
|
||||
|
||||
nacosWorker, err := getWorker(nacos.NewFactory(), &nacos.Config{
|
||||
Name: "nacos_1",
|
||||
Driver: "nacos",
|
||||
Labels: map[string]string{
|
||||
"scheme": "http",
|
||||
},
|
||||
Config: nacos.AccessConfig{
|
||||
Address: []string{"39.108.94.48:8848"},
|
||||
Params: map[string]string{
|
||||
"username": "test",
|
||||
"password": "test",
|
||||
"healthOnly": "false",
|
||||
},
|
||||
},
|
||||
}, "discovery", "nacos", "", "nacos", nil, "", "nacos_1", nil)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
nacosWorker.Start()
|
||||
allWorker := make(map[eosc.RequireId]interface{})
|
||||
allWorker["nacos_1@discovery"] = nacosWorker
|
||||
worker, err := getWorker(NewFactory(), nacosConfig, "upstream", "http_proxy", "", "http转发驱动", nil, "", "product-user", allWorker)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
|
||||
hUpstream, ok := worker.(upstream.IUpstream)
|
||||
if !ok {
|
||||
t.Error(ErrorStructType)
|
||||
|
||||
}
|
||||
data := url.Values{}
|
||||
data.Set("name", "eolinker")
|
||||
r, err := http.NewRequest("POST", "http://localhost:8080/Web/Test/params/print", strings.NewReader(data.Encode()))
|
||||
if err != nil {
|
||||
t.Error(ErrorStructType)
|
||||
}
|
||||
|
||||
ctx := http_context.NewContext(r, &response{})
|
||||
// 设置目标URL
|
||||
ctx.ProxyRequest.SetTargetURL(r.URL.Path)
|
||||
for i := 0; i < 10; i++ {
|
||||
now := time.Now()
|
||||
err = send(ctx, s, hUpstream)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
fmt.Println("spend time is", time.Now().Sub(now))
|
||||
}
|
||||
}
|
||||
85
upstream/upstream-http/upstream_static_test.go
Normal file
85
upstream/upstream-http/upstream_static_test.go
Normal file
@@ -0,0 +1,85 @@
|
||||
package upstream_http
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"strings"
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/eolinker/goku-eosc/discovery/nacos"
|
||||
|
||||
round_robin "github.com/eolinker/goku-eosc/upstream/round-robin"
|
||||
|
||||
http_context "github.com/eolinker/goku-eosc/node/http-context"
|
||||
|
||||
"github.com/eolinker/goku-eosc/upstream"
|
||||
|
||||
"github.com/eolinker/eosc"
|
||||
)
|
||||
|
||||
func TestNacos(t *testing.T) {
|
||||
round_robin.Register()
|
||||
nacosConfig := &Config{
|
||||
Name: "product-user",
|
||||
Driver: "http_proxy",
|
||||
Desc: "生产环境-用户模块",
|
||||
Scheme: "http",
|
||||
Type: "round-robin",
|
||||
Config: "nacos.naming.serviceName",
|
||||
Discovery: "nacos_1@discovery",
|
||||
}
|
||||
|
||||
nacosWorker, err := getWorker(nacos.NewFactory(), &nacos.Config{
|
||||
Name: "nacos_1",
|
||||
Driver: "nacos",
|
||||
Labels: map[string]string{
|
||||
"scheme": "http",
|
||||
},
|
||||
Config: nacos.AccessConfig{
|
||||
Address: []string{"39.108.94.48:8848"},
|
||||
Params: map[string]string{
|
||||
"username": "test",
|
||||
"password": "test",
|
||||
"healthOnly": "false",
|
||||
},
|
||||
},
|
||||
}, "discovery", "nacos", "", "nacos", nil, "", "nacos_1", nil)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
nacosWorker.Start()
|
||||
allWorker := make(map[eosc.RequireId]interface{})
|
||||
allWorker["nacos_1@discovery"] = nacosWorker
|
||||
worker, err := getWorker(NewFactory(), nacosConfig, "upstream", "http_proxy", "", "http转发驱动", nil, "", "product-user", allWorker)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
|
||||
hUpstream, ok := worker.(upstream.IUpstream)
|
||||
if !ok {
|
||||
t.Error(ErrorStructType)
|
||||
|
||||
}
|
||||
data := url.Values{}
|
||||
data.Set("name", "eolinker")
|
||||
r, err := http.NewRequest("POST", "http://localhost:8080/Web/Test/params/print", strings.NewReader(data.Encode()))
|
||||
if err != nil {
|
||||
t.Error(ErrorStructType)
|
||||
}
|
||||
|
||||
ctx := http_context.NewContext(r, &response{})
|
||||
// 设置目标URL
|
||||
ctx.ProxyRequest.SetTargetURL(r.URL.Path)
|
||||
for i := 0; i < 10; i++ {
|
||||
now := time.Now()
|
||||
err = send(ctx, s, hUpstream)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
fmt.Println("spend time is", time.Now().Sub(now))
|
||||
}
|
||||
}
|
||||
@@ -1,34 +1,31 @@
|
||||
package upstream_http
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"fmt"
|
||||
"io/ioutil"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"strings"
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/eolinker/goku-eosc/discovery/consul"
|
||||
"github.com/eolinker/goku-eosc/discovery/eureka"
|
||||
|
||||
round_robin "github.com/eolinker/goku-eosc/upstream/round-robin"
|
||||
|
||||
"github.com/eolinker/goku-eosc/discovery/static"
|
||||
|
||||
"github.com/eolinker/goku-eosc/service"
|
||||
|
||||
http_context "github.com/eolinker/goku-eosc/node/http-context"
|
||||
|
||||
"github.com/eolinker/goku-eosc/upstream"
|
||||
|
||||
"github.com/eolinker/eosc"
|
||||
http_context "github.com/eolinker/goku-eosc/node/http-context"
|
||||
"github.com/eolinker/goku-eosc/service"
|
||||
"github.com/eolinker/goku-eosc/upstream"
|
||||
)
|
||||
|
||||
var (
|
||||
ErrorStructType = "error struct type: %s, need struct type: %s"
|
||||
ErrorStructType = errors.New("error struct type")
|
||||
)
|
||||
|
||||
var s = &Service{
|
||||
name: "参数打印",
|
||||
desc: "打印所有参数",
|
||||
retry: 3,
|
||||
timeout: time.Second * 10,
|
||||
scheme: "http",
|
||||
}
|
||||
|
||||
type Service struct {
|
||||
name string
|
||||
desc string
|
||||
@@ -62,6 +59,10 @@ func (s *Service) ProxyAddr() string {
|
||||
return s.ProxyAddr()
|
||||
}
|
||||
|
||||
func TestUpstream(t *testing.T) {
|
||||
|
||||
}
|
||||
|
||||
func getWorker(factory eosc.IProfessionDriverFactory, cfg interface{}, profession string, name string, label string, desc string, params map[string]string, workerID, workerName string, worker map[eosc.RequireId]interface{}) (eosc.IWorker, error) {
|
||||
driver, err := factory.Create(profession, name, label, desc, params)
|
||||
if err != nil {
|
||||
@@ -71,201 +72,6 @@ func getWorker(factory eosc.IProfessionDriverFactory, cfg interface{}, professio
|
||||
return driver.Create(workerID, workerName, cfg, worker)
|
||||
}
|
||||
|
||||
var s = &Service{
|
||||
name: "参数打印",
|
||||
desc: "打印所有参数",
|
||||
retry: 3,
|
||||
timeout: time.Second * 10,
|
||||
scheme: "http",
|
||||
}
|
||||
|
||||
func TestConsul(t *testing.T) {
|
||||
round_robin.Register()
|
||||
consulConfig := &Config{
|
||||
Name: "product-user",
|
||||
Driver: "http_proxy",
|
||||
Desc: "生产环境-用户模块",
|
||||
Scheme: "http",
|
||||
Type: "round-robin",
|
||||
Config: "consul",
|
||||
Discovery: "consul_1@discovery",
|
||||
}
|
||||
|
||||
consulWorker, err := getWorker(consul.NewFactory(), &consul.Config{
|
||||
Name: "consul_1",
|
||||
Driver: "consul",
|
||||
Labels: map[string]string{
|
||||
"scheme": "http",
|
||||
},
|
||||
Config: consul.AccessConfig{
|
||||
Address: []string{"39.108.94.48:8500", "39.108.94.48:8501"},
|
||||
Params: map[string]string{"token": "a92316d8-5c99-4fa0-b4cd-30b9e66718aa"},
|
||||
},
|
||||
}, "discovery", "consul", "", "consul", nil, "", "consul_1", nil)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
consulWorker.Start()
|
||||
allWorker := make(map[eosc.RequireId]interface{})
|
||||
allWorker["consul_1@discovery"] = consulWorker
|
||||
worker, err := getWorker(NewFactory(), consulConfig, "upstream", "http_proxy", "", "http转发驱动", nil, "", "product-user", allWorker)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
|
||||
hUpstream, ok := worker.(upstream.IUpstream)
|
||||
if !ok {
|
||||
t.Error(ErrorStructType)
|
||||
|
||||
}
|
||||
data := url.Values{}
|
||||
data.Set("name", "eolinker")
|
||||
r, err := http.NewRequest("POST", "http://localhost:8080/Web/Test/params/print", strings.NewReader(data.Encode()))
|
||||
if err != nil {
|
||||
t.Error(ErrorStructType)
|
||||
}
|
||||
|
||||
ctx := http_context.NewContext(r, &response{})
|
||||
// 设置目标URL
|
||||
ctx.ProxyRequest.SetTargetURL(r.URL.Path)
|
||||
for i := 0; i < 10; i++ {
|
||||
now := time.Now()
|
||||
err = send(ctx, s, hUpstream)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
fmt.Println("spend time is", time.Now().Sub(now))
|
||||
}
|
||||
}
|
||||
|
||||
func TestEureka(t *testing.T) {
|
||||
round_robin.Register()
|
||||
eurekaConfig := &Config{
|
||||
Name: "product-user",
|
||||
Driver: "http_proxy",
|
||||
Desc: "生产环境-用户模块",
|
||||
Scheme: "http",
|
||||
Type: "round-robin",
|
||||
Config: "DEMO",
|
||||
Discovery: "eureka_1@discovery",
|
||||
}
|
||||
|
||||
eurekaWorker, err := getWorker(eureka.NewFactory(), &eureka.Config{
|
||||
Name: "eureka_1",
|
||||
Driver: "eureka",
|
||||
Labels: map[string]string{
|
||||
"scheme": "http",
|
||||
},
|
||||
Config: eureka.AccessConfig{
|
||||
Address: []string{"39.108.94.48:8761/eureka"},
|
||||
Params: map[string]string{
|
||||
"username": "test",
|
||||
"password": "test"},
|
||||
},
|
||||
}, "discovery", "eureka", "", "eureka", nil, "", "eureka_1", nil)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
eurekaWorker.Start()
|
||||
allWorker := make(map[eosc.RequireId]interface{})
|
||||
allWorker["eureka_1@discovery"] = eurekaWorker
|
||||
worker, err := getWorker(NewFactory(), eurekaConfig, "upstream", "http_proxy", "", "http转发驱动", nil, "", "product-user", allWorker)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
|
||||
hUpstream, ok := worker.(upstream.IUpstream)
|
||||
if !ok {
|
||||
t.Error(ErrorStructType)
|
||||
|
||||
}
|
||||
data := url.Values{}
|
||||
data.Set("name", "eolinker")
|
||||
r, err := http.NewRequest("POST", "http://localhost:8080/Web/Test/params/print", strings.NewReader(data.Encode()))
|
||||
if err != nil {
|
||||
t.Error(ErrorStructType)
|
||||
}
|
||||
|
||||
ctx := http_context.NewContext(r, &response{})
|
||||
// 设置目标URL
|
||||
ctx.ProxyRequest.SetTargetURL(r.URL.Path)
|
||||
for i := 0; i < 10; i++ {
|
||||
now := time.Now()
|
||||
err = send(ctx, s, hUpstream)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
fmt.Println("spend time is", time.Now().Sub(now))
|
||||
}
|
||||
}
|
||||
|
||||
func TestStatic(t *testing.T) {
|
||||
round_robin.Register()
|
||||
staticConfig := &Config{
|
||||
Name: "product-user",
|
||||
Driver: "http_proxy",
|
||||
Desc: "生产环境-用户模块",
|
||||
Scheme: "http",
|
||||
Type: "round-robin",
|
||||
Config: "127.0.0.1:8580 weight=10;47.95.203.198:8080 weight=20",
|
||||
Discovery: "static_1@discovery",
|
||||
}
|
||||
|
||||
staticWorker, err := getWorker(static.NewFactory(), &static.Config{
|
||||
Name: "static_1",
|
||||
Driver: "static",
|
||||
Labels: nil,
|
||||
Health: &static.HealthConfig{
|
||||
Protocol: "http",
|
||||
Method: "POST",
|
||||
URL: "/Web/Test/params/print",
|
||||
SuccessCode: 200,
|
||||
Period: 30,
|
||||
Timeout: 3000,
|
||||
},
|
||||
HealthOn: true,
|
||||
}, "discovery", "static", "", "静态服务发现", nil, "", "static_1", nil)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
allWorker := make(map[eosc.RequireId]interface{})
|
||||
allWorker["static_1@discovery"] = staticWorker
|
||||
worker, err := getWorker(NewFactory(), staticConfig, "upstream", "http_proxy", "", "http转发驱动", nil, "", "product-user", allWorker)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
return
|
||||
}
|
||||
|
||||
hUpstream, ok := worker.(upstream.IUpstream)
|
||||
if !ok {
|
||||
t.Error(ErrorStructType)
|
||||
|
||||
}
|
||||
data := url.Values{}
|
||||
data.Set("name", "eolinker")
|
||||
r, err := http.NewRequest("POST", "http://localhost:8080/Web/Test/params/print", strings.NewReader(data.Encode()))
|
||||
if err != nil {
|
||||
t.Error(ErrorStructType)
|
||||
}
|
||||
|
||||
ctx := http_context.NewContext(r, &response{})
|
||||
// 设置目标URL
|
||||
ctx.ProxyRequest.SetTargetURL(r.URL.Path)
|
||||
for i := 0; i < 10; i++ {
|
||||
now := time.Now()
|
||||
err = send(ctx, s, hUpstream)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
fmt.Println("spend time is", time.Now().Sub(now))
|
||||
}
|
||||
}
|
||||
|
||||
func send(ctx *http_context.Context, s service.IServiceDetail, hUpstream upstream.IUpstream) error {
|
||||
resp, err := hUpstream.Send(ctx, s)
|
||||
if err != nil {
|
||||
|
||||
Reference in New Issue
Block a user