Привет! Я поставщик весны для затвора, и сегодня я хочу поговорить о том, как управлять коммуникацией микросервисов весной для наших продуктов затвора. Это немного техническая тема, но я сделаю все возможное, чтобы разбить ее так, чтобы это было легко понять.
Во -первых, давайте поговорим о том, почему коммуникация MicroServices так важна для нашей весны для Leatter Business. В мире изготовления затвора у нас есть куча разных компонентов и процессов. Например, у нас естьБоковая рамка ролика 90 °,Корона трансмиссии роликового затвораиКолочкоАнкет Каждая из этих частей может управляться различным микросервисом в нашей системе на основе пружины.
Когда эти микросервисы не могут хорошо общаться, это похоже на то, как на фабрике куча людей не разговаривать друг с другом. В итоге вы получаете задержки, ошибки и множество головных болей. Таким образом, мы должны убедиться, что эти микросервисы могут обмениваться информацией плавно.
Одним из ключевых способов управления связи микросервисов весной является RESTFUL API. REST (репрезентативный государственный трансфер) - это действительно популярный способ создания веб -сервисов. В нашей пружине для системы затвора мы можем создать RESTFUL конечные точки для каждого микросервиса. Например, если у нас есть микросервис, который управляет инвентаризацией [боковой рамки на роликовом затворе 90 °], он может выявить API REST, который другие микросервисы могут использовать для проверки уровней запаса.
Вот простой пример того, как мы можем создать Restful API весной. Мы будем использовать Spring Boot, который является отличной основой для быстрого строительства приложений на основе пружины.
Импорт org.springframework.boot.springapplication; Импорт org.springframework.boot.autoconfigure.springbootapplication; Импорт org.springframework.web.bind.annotation.getMaping; Импорт org.springframework.web.bind.annotation.restcontroller; @Springbootapplication @restcontroller public class shutterinentoryservice {public static void main (string [] args) {springapplication.run (shutterinentoryService.class, args); } @GetMapping ("/Inventory/Roller-Shutter-Side-Frame-90") public int getRollerShutterSideFrame90inventory () {// Здесь мы фактически запрашиваем базу данных, чтобы получить количество инвентаризации return 10; }}В этом коде мы создали простой API Restful, который возвращает количество инвентаризации [боковой кадры роликового затвора 90 °]. Другие микросервисы могут затем вызвать этот API с помощью HTTP GET запросов, чтобы получить необходимую им информацию.
Другим важным аспектом связи микросервисов является общение на основе сообщений. Spring обеспечивает отличную поддержку систем на основе сообщений с помощью таких технологий, как Spring Cloud Stream. Благодаря сообщению - общению, микросервисы могут отправлять и получать сообщения асинхронно.
Допустим, у нас есть микросервис, который обрабатывает заказы для [колеса [роликового затвора]. Когда заказ размещен, этот микросервис может отправить сообщение брокеру сообщения (например, Kafka или Rabbitmq). Другие микросервисы, такие как микросервис управления запасами, могут затем прослушать эти сообщения и соответствующим образом обновить инвентарь.
Вот пример того, как мы можем использовать Spring Cloud Stream для отправки и получения сообщений:
Импорт org.springframework.cloud.stream.annotation.enableBinding; импорт org.springframework.cloud.stream.annotation.input; Импорт org.springframework.cloud.stream.annotation.output; Import org.springframework.cloud.stream.annotation.streamListener; Импорт org.springframework.messaging.messageChannel; Импорт org.springframework.messaging.support.messagebuilder; Импорт org.springframework.stereotype.service; импортировать java.util.logging.logger; интерфейс ShutterOrderOrderNels {string input = "shutter - order - input"; String output = "shutter - order - output"; @Input (input) org.springframework.messaging.subscribableechannel input (); @Output (output) messageChannel output (); } @EnableBinding (shutterOrderOrchannels.class) @service public class shutterorderservice {private static final logger logger = logger.getlogger (shutterorderservice.class.getName ()); частные финальные каналы ShutterOrderOrderNels; public shutterorderderservice (каналы ShutterOrderOrderNels) {this.Channels = каналы; } public void sendordermessage (строка порядка) {channels.output (). Send (messageBuilder.withPayload (order) .build ()); } @StreamListener (shutterOrderOrchannels.Input) public void handleordermessage (строка порядка) {logger.info ("Полученный заказ:" + order); // Здесь мы можем что -то сделать с заказом, например, обновление инвентаризации}}В этом коде мы создали услугу, которая может отправлять и получать сообщения, связанные с заказами за закрытие. Таким образом, различные микросервисы могут общаться друг с другом асинхронным и развязенным образом.
Когда дело доходит до управления коммуникацией микросервисов в реальном сценарии мира, нам также нужно подумать о обнаружении услуг. В большой пружине для системы затвора может быть десятки или даже сотни микросервисов. Для каждого микросервиса не практично знать точное местоположение (IP -адрес и порт) любого другого микросервиса, с которым необходимо общаться.
Spring Cloud Netflix Eureka - отличный инструмент для обнаружения услуг. Микросервисы могут зарегистрироваться на сервере Eureka, а другие микросервисы могут затем искать местонахождение услуг, которые им нужны через сервер Eureka.
Вот как мы можем настроить сервер Eureka в Spring Boot:
Импорт org.springframework.boot.springapplication; Импорт org.springframework.boot.autoconfigure.springbootapplication; Import org.springframework.cloud.netflix.eureka.server.enableteurekaserver; @Springbootapplication @enableeurekaserver public class shuttereurekaserver {public static void main (string [] args) {springapplication.run (shuttereurekaserver.class, args); }}И вот как микросервис может зарегистрироваться на сервере Eureka:
Импорт org.springframework.boot.springapplication; Импорт org.springframework.boot.autoconfigure.springbootapplication; Импорт org.springframework.cloud.netflix.eureka.enableteurekaclient; @Springbootapplication @enableeurekaclient public class shuttermicroservice {public static void main (string [] args) {SpringApplication.run (shuttermicroservice.class, args); }}Используя Eureka, наши микросервисы могут легко найти и общаться друг с другом без необходимости жесткой - кодировать места обслуживания.
В заключение, управление коммуникацией микросервисов весной для наших продуктов затвора имеет решающее значение для бесперебойной работы нашего бизнеса. Будь то с помощью RESTFUL API, сообщений, основанных на общении или обнаружения услуг, у нас есть много инструментов в нашем распоряжении.
Если вы находитесь на рынке для высокой - качественной пружины для продуктов затвора и интересуетесь тем, как мы управляем нашими микросервисами, чтобы обеспечить топ -качество и эффективность, я бы хотел поболтать с вами. Мы можем обсудить ваши конкретные потребности и то, как наши продукты могут вписаться в ваш бизнес. Не стесняйтесь обращаться к обсуждению закупок.
Ссылки
- Весенняя загрузочная документация
- Весенняя облачная документация
- Лучшие практики дизайна API Restful
- Сообщение - общение на основе распределенных систем
