springcloud (1) - интегрированная ракета spring-cloud-alibaba

Spring Cloud

предисловие

В предыдущей работе микросервисный фреймворк использовал springcloud, а промежуточное ПО для сообщений — RocketMQ.За это время я увидел, что Alibaba выпустила Spring Cloud и Alibaba интегрировала RocketMQ.Из любопытства написал демо

некоторые понятия

  • Официальное введение в Spring Cloud Stream: Spring Cloud Stream — это платформа для создания приложений микрослужб на основе сообщений. Создайте автономное приложение Spring производственного уровня на основе SpringBoot и используйте Spring Integration для подключения к брокеру.
  • Binder: Компоненты, отвечающие за интеграцию с внешними системами обмена сообщениями [Интеграция с промежуточным программным обеспечением внешнего обмена сообщениями].
  • Связывание: Мост между внешними системами обмена сообщениями и приложением, предоставляемым производителями и потребителями сообщений (созданный целевыми связывателями) [Обеспечивает мост между промежуточным программным обеспечением сообщений и поставщиком и потребителем, предоставляемым приложением, разработчикам нужно только использовать приложение производителю или потребителю программы нужно только производить или потреблять данные, что защищает разработчика от контакта с базовым промежуточным программным обеспечением сообщений. 】
  • Сообщение: каноническая структура данных, используемая производителями и потребителями для связи с целевыми связывателями (и, следовательно, другими приложениями через внешние системы обмена сообщениями) [Каноническая структура данных, используемая производителями и потребителями для связи с целевыми связывателями. 】

Быстро запустить RocketMQ локально

Шаг 1: Загрузите:woohoo.apache.org/wish you/closer. …Шаг 2: Разархивируйте Шаг 3: Измените три файла конфигурации: runbroker.sh, runserver.sh, tools.sh и измените JAVA_HOME на конфигурацию среды вашего компьютера.

[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=自己的地址
#[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!"

Шаг 4: Выполните команды последовательно

./mqnamesrv
./mqbroker -n localhost:9876
./mqadmin updateTopic -n localhost:9876 -c DefaultCluster -t test-topic

Если запуск прошел успешно и об ошибке не сообщается, это означает, что запуск прошел успешно, и вы можете развить его ниже.

разработать демо

Шаг 1: Импортируйте соответствующий pom

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>0.2.1.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
 </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-rocketmq</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
         <!-- 为了Endpoint 信息查看 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>io.dropwizard.metrics</groupId>
            <artifactId>metrics-core</artifactId>
            <version>3.2.6</version>
        </dependency>

Шаг 2: Создайте проект Springboot, класс запуска выглядит следующим образом:

@SpringBootApplication
@EnableBinding({ Source.class, Sink.class })
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

Шаг 3. Создайте поставщика

@Service
public class RocketmqProducer {
    public void send(String message) throws MQClientException, RemotingException, InterruptedException, MQBrokerException {
        DefaultMQProducer producer = new DefaultMQProducer("test_producer_group");
        producer.setNamesrvAddr("127.0.0.1:9876");
        producer.start();

        Message msg = new Message("test-topic", "test-tag", message.getBytes());
        producer.send(msg);
    }
}

Шаг 4: Создайте потребителя

@Service
public class ReceiveService {

    /**
     * 默认是input，在Sink类中指定，如果想要多个input，需要写一个实现Sink的类
     * @param receiveMsg
     */
    @StreamListener("input")
    public void receiveInput1(String receiveMsg) {
        System.out.println("input receive: " + receiveMsg);
    }

}

Шаг 5: Добавьте файл конфигурации:

server.port=8087
spring.application.name=spring-cloud-alibaba-rocketmq-demo

# 配置rocketmq的nameserver地址
spring.cloud.stream.rocketmq.binder.namesrv-addr=127.0.0.1:9876
# 定义name为output的binding
spring.cloud.stream.bindings.output.destination=test-topic
spring.cloud.stream.bindings.output.content-type=application/json
#定义name为input的binding
spring.cloud.stream.bindings.input.destination=test-topic
spring.cloud.stream.bindings.input.content-type=application/json
spring.cloud.stream.bindings.input.group=test-group

management.endpoint.health.show-details=always

Шаг 6: Напишите контроллер, запустите проект и получите доступ к интерфейсу

@RestController
@RequestMapping(value = "/api/demo/test")
public class TestController {

    @Autowired
    RocketmqProducer rocketmqProducer;

    @RequestMapping(value = "/send", method = RequestMethod.GET)
    public String send() throws InterruptedException, RemotingException, MQClientException, MQBrokerException {
        rocketmqProducer.send("test rocketmq message");
        return "success";
    }
}

Вы увидите вывод консоли: input receive: test robotmq message

Представление информации о конечной точке

Вход через браузер:http://127.0.0.1:8087/actuator/rocketmq-binder

Эпилог

Эта статья просто запускает spring cloud stream и RocketMQ, На самом деле Spring Cloud stream и RocketMQ все еще находятся в стадии изучения, Я могу только вздохнуть, что Spring Cloud широк и глубок.

Можно получить доступ к большему количеству веб-сайтовwww.zplxjj.comИли обратите внимание на общедоступный номер:

Категории