Go Microservices: Часть 8. Централизованная настройка с помощью Viper и Spring Cloud Config

Я предполагаю, что многие из нас сталкивались с ситуациями, когда нам нужно либо перестроить целое приложение, либо хотя бы перезапустить его, чтобы обновить какое-либо недопустимое или измененное значение конфигурации. Spring Cloud имеет концепцию @RefreshScope, в которой бины могут обновляться в реальном времени с измененной конфигурацией, передаваемой из ловушки git commit .

На этом рисунке представлен обзор того, как пуш к git-репо распространяется на наши микросервисы на основе Go:

В этом сообщении мы используем репозиторий GitHub, у которого нет абсолютно никакой возможности узнать, как выполнить операцию перехвата после фиксации на сервере Spring Cloud моего ноутбука, поэтому мы будем эмулировать перехват фиксации фиксации с помощью встроенного / контролировать конечную точку нашего сервера Spring Cloud Config.

curl -H "X-Github-Event: push" -H "Content-Type: application/json" -X POST -d '{"commits": [{"modified": ["accountservice.yml"]}],"name":"some name..."}' -ki http://$ManagerIP:8888/monitor

Сервер Spring Cloud Config будет знать, что делать с этим POST, и отправлять RefreshRemoteApplicationEvent в обмен на RabbitMQ (абстрагируется от Spring Cloud Bus). Если мы посмотрим на графический интерфейс администратора RabbitMQ после успешной загрузки Spring Cloud Config, этот обмен должен был быть создан:

Как обмен связан с более традиционными структурами обмена сообщениями, такими как издатель, потребитель и очередь?

Publisher -> Exchange -> (Routing) -> Queue -> Consumer

Например, сообщение публикуется на бирже , которая затем распределяет копии сообщений в очередь (и) на основе правил маршрутизации и привязок, которые могут иметь зарегистрированные потребители .

Поэтому, чтобы использовать сообщения RefreshRemoteApplicationEvent (я предпочитаю называть их токенами обновления ), все, что нам нужно сейчас сделать, — это заставить наш сервис Go прослушивать такие сообщения в обмене springCloudBus и, если мы являемся целевым приложением, выполнить перезагрузку конфигурации. Давайте сделаем это.

Использование протокола AMQP для потребления сообщений в Go

Доступ к брокеру RabbitMQ можно получить по протоколу AMQP. Есть хороший клиент Go AMQP, который мы будем использовать, называемый streadway / amqp . Большая часть сантехнического кода AMQP / RabbitMQ должна входить в какую-то утилиту многократного использования, возможно, мы ее рефакторинг позже. Сантехнический код основан на этом примере из репозитория streadway / amqp.

В /goblog/accountservice/main.go добавьте новую строку внутри функции main () , которая запустит для нас потребителя AMQP:

func main() {
        fmt.Printf("Starting %v\n", appName)

        config.LoadConfigurationFromBranch(
                viper.GetString("configServerUrl"),
                appName,
                viper.GetString("profile"),
                viper.GetString("configBranch"))
        initializeBoltClient()

        // NEW
        go config.StartListener(appName, viper.GetString("amqp_server_url"), viper.GetString("config_event_bus"))   
        service.StartWebServer(viper.GetString("server_port"))
}

func StartListener(appName string, amqpServer string, exchangeName string) {
        err := NewConsumer(amqpServer, exchangeName, "topic", "config-event-queue", exchangeName, appName)
        if err != nil {
                log.Fatalf("%s", err)
        }

        log.Printf("running forever")
        select {}   // Yet another way to stop a Goroutine from finishing...
}

 func handleRefreshEvent(body []byte, consumerTag string) {
         updateToken := &UpdateToken{}
         err := json.Unmarshal(body, updateToken)
         if err != nil {
                 log.Printf("Problem parsing UpdateToken: %v", err.Error())
         } else {
                 if strings.Contains(updateToken.DestinationService, consumerTag) {
                         log.Println("Reloading Viper config from Spring Cloud Config server")

                         // Consumertag is same as application name.
                         LoadConfigurationFromBranch(
                                 viper.GetString("configServerUrl"),
                                 consumerTag,
                                 viper.GetString("profile"),
                                 viper.GetString("configBranch"))
                 }
         }
 }

 type UpdateToken struct {
         Type string `json:"type"`
         Timestamp int `json:"timestamp"`
         OriginService string `json:"originService"`
         DestinationService string `json:"destinationService"`
         Id string `json:"id"`
 }

var SERVICE_NAME = "accountservice"

func TestHandleRefreshEvent(t *testing.T) {
        // Configure initial viper values
        viper.Set("configServerUrl", "http://configserver:8888")
        viper.Set("profile", "test")
        viper.Set("configBranch", "master")

        // Mock the expected outgoing request for new config
        defer gock.Off()
        gock.New("http://configserver:8888").
                Get("/accountservice/test/master").
                Reply(200).
                BodyString(`{"name":"accountservice-test","profiles":["test"],"label":null,"version":null,"propertySources":[{"name":"file:/config-repo/accountservice-test.yml","source":{"server_port":6767,"server_name":"Accountservice RELOADED"}}]}`)

        Convey("Given a refresh event received, targeting our application", t, func() {
                var body = `{"type":"RefreshRemoteApplicationEvent","timestamp":1494514362123,"originService":"config-server:docker:8888","destinationService":"accountservice:**","id":"53e61c71-cbae-4b6d-84bb-d0dcc0aeb4dc"}
`
                Convey("When handled", func() {
                        handleRefreshEvent([]byte(body), SERVICE_NAME)

                        Convey("Then Viper should have been re-populated with values from Source", func() {
                              So(viper.GetString("server_name"), ShouldEqual, "Accountservice RELOADED")
                        })
                })
        })
}

> ./copyall.sh

> docker logs -f [containerid]
Starting accountservice
... [truncated for brevity] ...
Successfully loaded configuration for service Accountservice TEST    <-- LOOK HERE!!!!
... [truncated for brevity] ...
2017/05/12 12:06:36 dialing amqp://guest:guest@rabbitmq:5672/
2017/05/12 12:06:36 got Connection, getting Channel
2017/05/12 12:06:36 got Channel, declaring Exchange (springCloudBus)
2017/05/12 12:06:36 declared Exchange, declaring Queue (config-event-queue)
2017/05/12 12:06:36 declared Queue (0 messages, 0 consumers), binding to Exchange (key 'springCloudBus')
2017/05/12 12:06:36 Queue bound to Exchange, starting Consume (consumer tag 'accountservice')
2017/05/12 12:06:36 running forever

> curl -H "X-Github-Event: push" -H "Content-Type: application/json" -X POST -d '{"commits": [{"modified": ["accountservice.yml"]}],"name":"what is this?"}' -ki http://192.168.99.100:8888/monitor

> docker logs -f [containerid]
2017/05/12 12:13:22 got 195B consumer: [accountservice] delivery: [1] routingkey: [springCloudBus] {"type":"RefreshRemoteApplicationEvent","timestamp":1494591202057,"originService":"config-server:docker:8888","destinationService":"accountservice:**","id":"1f421f58-cdd6-44c8-b5c4-fbf1e2839baa"}
2017/05/12 12:13:22 Reloading Viper config from Spring Cloud Config server
Loading config from http://configserver:8888/accountservice/test/P8
Loading config property server_port => 6767
Loading config property server_name => Temporary test string!
Loading config property amqp_server_url => amqp://guest:guest@rabbitmq:5672/
Loading config property config_event_bus => springCloudBus
Loading config property the_password => password
Successfully loaded configuration for service Temporary test string!      <-- LOOK HERE!!!!

if viper.IsSet("server_name") {
        fmt.Printf("Successfully loaded configuration for service %s\n", viper.GetString("server_name"))
}    

CONTAINER                                    CPU %               MEM USAGE / LIMIT     MEM %               NET I/O             BLOCK I/O           PIDS
accountservice.1.pi7wt0wmh2quwm8kcw4e82ay4   0.02%               4.102MiB / 1.955GiB   0.20%               18.8kB / 16.5kB     0B / 1.92MB         6
configserver.1.3joav3m6we6oimg28879gii79     0.13%               568.7MiB / 1.955GiB   28.41%              171kB / 130kB       72.9MB / 225kB      50
rabbitmq.1.kfmtsqp5fnw576btraq19qel9         0.19%               125.5MiB / 1.955GiB   6.27%               6.2MB / 5.18MB      31MB / 414kB        75
quotes-service.1.q81deqxl50n3xmj0gw29mp7jy   0.05%               340.1MiB / 1.955GiB   16.99%              2.97kB / 0B         48.1MB / 0B         30