Skip to content

P
prog-7-java-rabit-mq
Commit 63eabc2a authored by Чирцов Тимофей Александрович's avatar Чирцов Тимофей Александрович
Browse files
Options

Initial commit

parent 94930ffb
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 920 additions and 0 deletions
.gitattributes 0 → 100644
View file @ 63eabc2a
/mvnw text eol=lf
*.cmd text eol=crlf
.gitignore 0 → 100644
View file @ 63eabc2a
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
.mvn/wrapper/maven-wrapper.properties 0 → 100644
View file @ 63eabc2a
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
wrapperVersion=3.3.2
distributionType=only-script
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.9/apache-maven-3.9.9-bin.zip
README.md 0 → 100644
View file @ 63eabc2a
### Чирцов Т А группа 1.1
# Лабораторная работа по использованию RabbitMQ в Java Spring
## Обзор проекта
Проект включает:
- **ProducerController**: отправка сообщений в очередь RabbitMQ.
- **PublisherController**: публикация сообщений в обмен.
- **Subscriber** и **Consumer**: приём сообщений.
- **SubscriberWithRouting**: подписчик на очереди `info` и `error`.
## Настройка окружения
### 1. Запуск RabbitMQ
Команда для запуска контейнера:
```bash
sudo docker run -d --hostname rabbitmq --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
```
Веб-интерфейс будет доступен на `localhost:15672`, брокер сообщений — на `localhost:5672`.
### 2. Установка зависимостей
Убедитесь, что установлен JDK 23, и выполните:
```bash
mvn clean install
```
### 3. Запуск приложения
Команда для запуска:
```bash
mvn spring-boot:run
```
Приложение откроется на `localhost:8080`.
## Проверка работы с Curl
### Тест 1: `ProducerController`
**Метод:** POST
**URL:** `http://localhost:8080/api/producer/send?message=<ваше_сообщение>`
**Пример:**
```bash
curl -X POST "http://localhost:8080/api/producer/send?message=Hello%20RabbitMQ"
```
**Результат:**
```
Сообщение добавлено в очередь: task_queue, текст: Hello RabbitMQ
```
### Тест 2: `PublisherController`
**Метод:** POST
**URL:** `http://localhost:8080/api/publisher/publish?message=<сообщение>&routingKey=<ключ>`
С ключом маршрутизации:
```bash
curl -X POST "http://localhost:8080/api/publisher/publish?message=Log%20message&routingKey=info"
```
Без ключа:
```bash
curl -X POST "http://localhost:8080/api/publisher/publish?message=Log%20message"
```
**Ответ:**
```
Сообщение отправлено в direct_logs с ключом: info
```
или:
```
Сообщение отправлено в logs без ключа
```
### Тест 3: `Subscriber`
При публикации через `ProducerController` или `PublisherController`:
```
Получено сообщение: Log message
```
### Тест 4: `Consumer`
При отправке сообщения в `task_queue`:
```
Получено сообщение из очереди задач: Hello RabbitMQ
```
### Тест 5: `SubscriberWithRouting`
**Очередь `info`:**
```bash
curl -X POST "http://localhost:8080/api/publisher/publish?message=Informational%20message&routingKey=info"
```
**Результат:**
```
Информационное сообщение: Informational message
```
**Очередь `error`:**
```bash
curl -X POST "http://localhost:8080/api/publisher/publish?message=Error%20message&routingKey=error"
```
**Результат:**
```
Ошибка: Error message
```
# Скриншоты:
![Consumer.png](images/Consumer.png)
![Producer.png](images/Producer.png)
![ProducerController.png](images/ProducerController.png)
![Publisher.png](images/Publisher.png)
![PublisherController.png](images/PublisherController.png)
![PublisherWithRouting.png](images/PublisherWithRouting.png)
![Subscriber.png](images/Subscriber.png)
![SubscriberWithRouting.png](images/SubscriberWithRouting.png)
\ No newline at end of file
mvnw 0 → 100755
View file @ 63eabc2a
This diff is collapsed.
mvnw.cmd 0 → 100644
View file @ 63eabc2a
<# : batch portion
@REM ----------------------------------------------------------------------------
@REM Licensed to the Apache Software Foundation (ASF) under one
@REM or more contributor license agreements. See the NOTICE file
@REM distributed with this work for additional information
@REM regarding copyright ownership. The ASF licenses this file
@REM to you under the Apache License, Version 2.0 (the
@REM "License"); you may not use this file except in compliance
@REM with the License. You may obtain a copy of the License at
@REM
@REM http://www.apache.org/licenses/LICENSE-2.0
@REM
@REM Unless required by applicable law or agreed to in writing,
@REM software distributed under the License is distributed on an
@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@REM KIND, either express or implied. See the License for the
@REM specific language governing permissions and limitations
@REM under the License.
@REM ----------------------------------------------------------------------------
@REM ----------------------------------------------------------------------------
@REM Apache Maven Wrapper startup batch script, version 3.3.2
@REM
@REM Optional ENV vars
@REM MVNW_REPOURL - repo url base for downloading maven distribution
@REM MVNW_USERNAME/MVNW_PASSWORD - user and password for downloading maven
@REM MVNW_VERBOSE - true: enable verbose log; others: silence the output
@REM ----------------------------------------------------------------------------
@IF "%__MVNW_ARG0_NAME__%"=="" (SET __MVNW_ARG0_NAME__=%~nx0)
@SET __MVNW_CMD__=
@SET __MVNW_ERROR__=
@SET __MVNW_PSMODULEP_SAVE=%PSModulePath%
@SET PSModulePath=
@FOR /F "usebackq tokens=1* delims==" %%A IN (`powershell -noprofile "& {$scriptDir='%~dp0'; $script='%__MVNW_ARG0_NAME__%'; icm -ScriptBlock ([Scriptblock]::Create((Get-Content -Raw '%~f0'))) -NoNewScope}"`) DO @(
IF "%%A"=="MVN_CMD" (set __MVNW_CMD__=%%B) ELSE IF "%%B"=="" (echo %%A) ELSE (echo %%A=%%B)
)
@SET PSModulePath=%__MVNW_PSMODULEP_SAVE%
@SET __MVNW_PSMODULEP_SAVE=
@SET __MVNW_ARG0_NAME__=
@SET MVNW_USERNAME=
@SET MVNW_PASSWORD=
@IF NOT "%__MVNW_CMD__%"=="" (%__MVNW_CMD__% %*)
@echo Cannot start maven from wrapper >&2 && exit /b 1
@GOTO :EOF
: end batch / begin powershell #>
$ErrorActionPreference = "Stop"
if ($env:MVNW_VERBOSE -eq "true") {
$VerbosePreference = "Continue"
}
# calculate distributionUrl, requires .mvn/wrapper/maven-wrapper.properties
$distributionUrl = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionUrl
if (!$distributionUrl) {
Write-Error "cannot read distributionUrl property in $scriptDir/.mvn/wrapper/maven-wrapper.properties"
}
switch -wildcard -casesensitive ( $($distributionUrl -replace '^.*/','') ) {
"maven-mvnd-*" {
$USE_MVND = $true
$distributionUrl = $distributionUrl -replace '-bin\.[^.]*$',"-windows-amd64.zip"
$MVN_CMD = "mvnd.cmd"
break
}
default {
$USE_MVND = $false
$MVN_CMD = $script -replace '^mvnw','mvn'
break
}
}
# apply MVNW_REPOURL and calculate MAVEN_HOME
# maven home pattern: ~/.m2/wrapper/dists/{apache-maven-<version>,maven-mvnd-<version>-<platform>}/<hash>
if ($env:MVNW_REPOURL) {
$MVNW_REPO_PATTERN = if ($USE_MVND) { "/org/apache/maven/" } else { "/maven/mvnd/" }
$distributionUrl = "$env:MVNW_REPOURL$MVNW_REPO_PATTERN$($distributionUrl -replace '^.*'+$MVNW_REPO_PATTERN,'')"
}
$distributionUrlName = $distributionUrl -replace '^.*/',''
$distributionUrlNameMain = $distributionUrlName -replace '\.[^.]*$','' -replace '-bin$',''
$MAVEN_HOME_PARENT = "$HOME/.m2/wrapper/dists/$distributionUrlNameMain"
if ($env:MAVEN_USER_HOME) {
$MAVEN_HOME_PARENT = "$env:MAVEN_USER_HOME/wrapper/dists/$distributionUrlNameMain"
}
$MAVEN_HOME_NAME = ([System.Security.Cryptography.MD5]::Create().ComputeHash([byte[]][char[]]$distributionUrl) | ForEach-Object {$_.ToString("x2")}) -join ''
$MAVEN_HOME = "$MAVEN_HOME_PARENT/$MAVEN_HOME_NAME"
if (Test-Path -Path "$MAVEN_HOME" -PathType Container) {
Write-Verbose "found existing MAVEN_HOME at $MAVEN_HOME"
Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"
exit $?
}
if (! $distributionUrlNameMain -or ($distributionUrlName -eq $distributionUrlNameMain)) {
Write-Error "distributionUrl is not valid, must end with *-bin.zip, but found $distributionUrl"
}
# prepare tmp dir
$TMP_DOWNLOAD_DIR_HOLDER = New-TemporaryFile
$TMP_DOWNLOAD_DIR = New-Item -Itemtype Directory -Path "$TMP_DOWNLOAD_DIR_HOLDER.dir"
$TMP_DOWNLOAD_DIR_HOLDER.Delete() | Out-Null
trap {
if ($TMP_DOWNLOAD_DIR.Exists) {
try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
}
}
New-Item -Itemtype Directory -Path "$MAVEN_HOME_PARENT" -Force | Out-Null
# Download and Install Apache Maven
Write-Verbose "Couldn't find MAVEN_HOME, downloading and installing it ..."
Write-Verbose "Downloading from: $distributionUrl"
Write-Verbose "Downloading to: $TMP_DOWNLOAD_DIR/$distributionUrlName"
$webclient = New-Object System.Net.WebClient
if ($env:MVNW_USERNAME -and $env:MVNW_PASSWORD) {
$webclient.Credentials = New-Object System.Net.NetworkCredential($env:MVNW_USERNAME, $env:MVNW_PASSWORD)
}
[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12
$webclient.DownloadFile($distributionUrl, "$TMP_DOWNLOAD_DIR/$distributionUrlName") | Out-Null
# If specified, validate the SHA-256 sum of the Maven distribution zip file
$distributionSha256Sum = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionSha256Sum
if ($distributionSha256Sum) {
if ($USE_MVND) {
Write-Error "Checksum validation is not supported for maven-mvnd. `nPlease disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties."
}
Import-Module $PSHOME\Modules\Microsoft.PowerShell.Utility -Function Get-FileHash
if ((Get-FileHash "$TMP_DOWNLOAD_DIR/$distributionUrlName" -Algorithm SHA256).Hash.ToLower() -ne $distributionSha256Sum) {
Write-Error "Error: Failed to validate Maven distribution SHA-256, your Maven distribution might be compromised. If you updated your Maven version, you need to update the specified distributionSha256Sum property."
}
}
# unzip and move
Expand-Archive "$TMP_DOWNLOAD_DIR/$distributionUrlName" -DestinationPath "$TMP_DOWNLOAD_DIR" | Out-Null
Rename-Item -Path "$TMP_DOWNLOAD_DIR/$distributionUrlNameMain" -NewName $MAVEN_HOME_NAME | Out-Null
try {
Move-Item -Path "$TMP_DOWNLOAD_DIR/$MAVEN_HOME_NAME" -Destination $MAVEN_HOME_PARENT | Out-Null
} catch {
if (! (Test-Path -Path "$MAVEN_HOME" -PathType Container)) {
Write-Error "fail to move MAVEN_HOME"
}
} finally {
try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
}
Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"
pom.xml 0 → 100644
View file @ 63eabc2a
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.4.1</version>
<relativePath /> <!-- lookup parent from repository -->
</parent>
<groupId>com.example</groupId>
<artifactId>rabbit</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>rabbit</name>
<description>Demo project for Spring Boot</description>
<url />
<licenses>
<license />
</licenses>
<developers>
<developer />
</developers>
<scm>
<connection />
<developerConnection />
<tag />
<url />
</scm>
<properties>
<java.version>23</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<!-- Spring Boot Starter Web -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Spring Boot Starter AMQP (RabbitMQ) -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<!-- Spring Boot Starter Actuator (optional for monitoring) -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!-- Spring Boot DevTools (optional for development, enables live reload) -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<scope>runtime</scope>
<optional>true</optional>
</dependency>
<!-- Lombok (optional for simplifying boilerplate code) -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<!-- Spring Boot Starter Test -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
<exclusions>
<exclusion>
<groupId>org.junit.vintage</groupId>
<artifactId>junit-vintage-engine</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
\ No newline at end of file
src/main/java/com/example/rabbit/RabbitApplication.java 0 → 100644
View file @ 63eabc2a
package com.example.rabbit;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class RabbitApplication {
public static void main(String[] args) {
SpringApplication.run(RabbitApplication.class, args);
}
}
src/main/java/com/example/rabbit/config/RabbitMQConfig.java 0 → 100644
View file @ 63eabc2a
package com.example.rabbit.config;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.amqp.core.Binding;
@Configuration
public class RabbitMQConfig {
// Настройка очереди для Task Queue
@Bean
public Queue taskQueue() {
return new Queue("task_queue", true); // durable = true
}
// Настройка Fanout exchange для Publish/Subscribe
@Bean
public FanoutExchange fanoutExchange() {
return new FanoutExchange("logs");
}
// Настройка Direct exchange для маршрутизации
@Bean
public TopicExchange directExchange() {
return new TopicExchange("direct_logs");
}
// Создание очереди "info"
@Bean
public Queue infoQueue() {
return new Queue("info", true); // Устойчивая очередь
}
// Создание очереди "error"
@Bean
public Queue errorQueue() {
return new Queue("error", true); // Устойчивая очередь
}
// Привязка "info" к exchange с routing key "info"
@Bean
public Binding bindingInfo(Queue infoQueue, TopicExchange directExchange) {
return BindingBuilder.bind(infoQueue).to(directExchange).with("info");
}
// Привязка "error" к exchange с routing key "error"
@Bean
public Binding bindingError(Queue errorQueue, TopicExchange directExchange) {
return BindingBuilder.bind(errorQueue).to(directExchange).with("error");
}
}
src/main/java/com/example/rabbit/controllers/ProducerController.java 0 → 100644
View file @ 63eabc2a
package com.example.rabbit.controllers;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/api/producer")
public class ProducerController {
private final RabbitTemplate rabbitTemplate;
private String queueName = "task_queue";
public ProducerController(RabbitTemplate rabbitTemplate) {
this.rabbitTemplate = rabbitTemplate;
}
@PostMapping("/send")
public ResponseEntity<String> sendMessage(@RequestParam String message) {
rabbitTemplate.convertAndSend(queueName, message);
return ResponseEntity.ok("Сообщение успешно добавлено в очередь: " + queueName + ", текст сообщения: " + message);
}
}
\ No newline at end of file
src/main/java/com/example/rabbit/controllers/PublisherController.java 0 → 100644
View file @ 63eabc2a
package com.example.rabbit.controllers;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/api/publisher")
public class PublisherController {
private final RabbitTemplate rabbitTemplate;
private String exchangeName = "direct_logs";
private String fallbackName = "logs";
public PublisherController(RabbitTemplate rabbitTemplate) {
this.rabbitTemplate = rabbitTemplate;
}
@PostMapping("/publish")
public ResponseEntity<String> publishMessage(@RequestParam String message, @RequestParam(required = false) String routingKey) {
String queue = routingKey != null ? exchangeName : fallbackName;
if (routingKey != null) {
// Если ключ маршрутизации присутствует
rabbitTemplate.convertAndSend(queue, routingKey, message);
} else {
// Если ключ маршрутизации не указан, отправляем в fallback очередь
rabbitTemplate.convertAndSend(queue, "", message);
}
return ResponseEntity.ok("Сообщение отправлено в обмен: " + queue + " с ключом маршрутизации: "
+ (routingKey != null ? routingKey : "без ключа маршрутизации") + ", текст сообщения: " + message);
}
}
src/main/java/com/example/rabbit/notifications/Publisher.java 0 → 100644
View file @ 63eabc2a
package com.example.rabbit.notifications;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;
@Component
public class Publisher {
@Autowired
private RabbitTemplate rabbitTemplate;
public void publishMessage(String message) {
rabbitTemplate.convertAndSend("logs", "", message);
System.out.println("Сообщение опубликовано: " + message);
}
}
\ No newline at end of file
src/main/java/com/example/rabbit/notifications/PublisherWithRouting.java 0 → 100644
View file @ 63eabc2a
package com.example.rabbit.notifications;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;
@Component
public class PublisherWithRouting {
@Autowired
private RabbitTemplate rabbitTemplate;
public void sendMessage(String routingKey, String message) {
rabbitTemplate.convertAndSend("direct_logs", routingKey, message);
System.out.println("Сообщение отправлено с ключом маршрутизации " + routingKey + ": " + message);
}
}
\ No newline at end of file
src/main/java/com/example/rabbit/notifications/Subscriber.java 0 → 100644
View file @ 63eabc2a
package com.example.rabbit.notifications;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@Component
public class Subscriber {
@RabbitListener(bindings = @QueueBinding(value = @Queue(value = "dynamic_queue", durable = "true"), exchange = @Exchange(value = "logs", type = "fanout")))
public void receiveMessage(String message) {
System.out.println("Получено сообщение: " + message);
}
}
\ No newline at end of file
src/main/java/com/example/rabbit/notifications/SubscriberWithRouting.java 0 → 100644
View file @ 63eabc2a
package com.example.rabbit.notifications;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@Component
public class SubscriberWithRouting {
@RabbitListener(queues = "info")
public void receiveInfoMessages(String message) {
System.out.println("Информационное сообщение получено: " + message);
}
@RabbitListener(queues = "error")
public void receiveErrorMessages(String message) {
System.out.println("Ошибка: получено сообщение: " + message);
}
}
\ No newline at end of file
src/main/java/com/example/rabbit/tasks/Consumer.java 0 → 100644
View file @ 63eabc2a
package com.example.rabbit.tasks;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@Component
public class Consumer {
@RabbitListener(queues = "task_queue")
public void receiveMessage(String message) {
System.out.println("Получено сообщение из очереди задач: " + message);
}
}
\ No newline at end of file
src/main/java/com/example/rabbit/tasks/Producer.java 0 → 100644
View file @ 63eabc2a
package com.example.rabbit.tasks;
import org.springframework.amqp.core.MessageProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;
@Component
public class Producer {
@Autowired
private RabbitTemplate rabbitTemplate;
public void sendTask(String message) {
rabbitTemplate.convertAndSend("task_queue", message, m -> {
m.getMessageProperties().setDeliveryMode(MessageProperties.DEFAULT_DELIVERY_MODE); // PERSISTENT
return m;
});
System.out.println("Задача отправлена: " + message);
}
}
\ No newline at end of file
src/main/resources/application.properties 0 → 100644
View file @ 63eabc2a
spring.application.name=rabbit
src/test/java/com/example/rabbit/RabbitApplicationTests.java 0 → 100644
View file @ 63eabc2a
package com.example.rabbit;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class RabbitApplicationTests {
@Test
void contextLoads() {
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment