前言

插件开发需要同时启动多个端口号不同的项目注册到consul , 并提供http接口服务

但是, java项目实在本地启动实在太慢了, 而且对同时启动多个相同的项目并不友好, 所以我使用go写了一份

注册consul

package consulcon

import (
	"fmt"
	consulApi "github.com/hashicorp/consul/api"
	"myIris/logger"
	"strconv"
)

const (
	consulAddress = "localhost:8500"
	localIp       = "docker.for.mac.host.internal"
)

// 注册服务到consul
func Register(port int) {
	portStr := strconv.Itoa(port)

	// 连接consul服务
	config := consulApi.DefaultConfig()
	// 宿主机访问容器中的consul
	config.Address = consulAddress
	client, err := consulApi.NewClient(config)
	if err != nil {
		logger.Log.Error("consul client error : ", err)
	}

	// 注册服务到consul
	registration := new(consulApi.AgentServiceRegistration)
	registration.ID = portStr
	registration.Name = "go-consul-test-" + portStr
	registration.Port = port
	registration.Tags = []string{"primary"}
	registration.Address = "localhost"
	// 容器中的consul访问宿主机 localhost 使用 docker.for.mac.host.internal 进行替换
	registration.Check = healthCheck(port)

	err = client.Agent().ServiceRegister(registration)
	if err != nil {
		logger.Log.Error("register: \n", err)
	}
	logger.Log.Info(" register successful")
}

// consul健康检查回调函数
func healthCheck(port int) *consulApi.AgentServiceCheck {
	check := new(consulApi.AgentServiceCheck)
	// 容器中的consul访问宿主机 localhost 使用 docker.for.mac.host.internal 进行替换
	check.HTTP = fmt.Sprintf("http://%s:%d/health", localIp, port)
	logger.Log.Info(check.HTTP)
	check.Timeout = "5s"
	check.Interval = "5s"
	check.DeregisterCriticalServiceAfter = "30s" // 故障检查失败30s后 consul自动将注册服务删除
	return check
}

main方法

package main

import (
	"github.com/kataras/iris/v12"
	"myIris/consulcon"
	"myIris/logger"
	"strconv"
)

func main() {
	logger.Init()
	go Init(8201)
	Init(8202)
}

func Init(port int) {
	// 注册服务到consul
	consulcon.Register(port)
	app := newApp()
	app.Listen(":" + strconv.Itoa(port))

}

func newApp() *iris.Application {
	app := iris.New()
	route(app)
	return app
}

func route(app *iris.Application) {
	// consul健康检查回调函数
	app.Handle("GET", "/health", func(ctx iris.Context) {
		ctx.JSON(iris.Map{"status": "ok"})
	})

	app.Handle("GET", "/query", func(ctx iris.Context) {
		ctx.JSON(iris.Map{"code": 200, "msg": "ok", "data": true})
	})

	app.Handle("POST", "/queryPOST", func(ctx iris.Context) {
		ctx.JSON(iris.Map{"code": 200, "msg": "ok", "data": true})
	})
}

查看consul注册状态

访问 http://127.0.0.1:8500/ui/dc1/services 如下图