Отчёт

lab3/.gitignore

@@ -0,0 +1,3 @@
+*.jpg
+*.pdf
+*.docx

lab3/consumer/.gitattributes

@@ -0,0 +1,9 @@
+#
+# https://help.github.com/articles/dealing-with-line-endings/
+#
+# Linux start script should use lf
+/gradlew        text eol=lf
+
+# These are Windows script files and should use crlf
+*.bat           text eol=crlf
+

lab3/consumer/.gitignore

@@ -0,0 +1,5 @@
+# Ignore Gradle project-specific cache directory
+.gradle
+
+# Ignore Gradle build output directory
+build

lab3/consumer/.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+    "java.configuration.updateBuildConfiguration": "interactive"
+}

lab3/consumer/Dockerfile

@@ -0,0 +1,9 @@
+FROM gradle:8.13-jdk21
+
+WORKDIR /app
+
+COPY . .
+
+RUN gradle build --no-daemon
+
+CMD ["gradle", "run", "--no-daemon"]

lab3/consumer/app/build.gradle

@@ -0,0 +1,42 @@
+/*
+ * This file was generated by the Gradle 'init' task.
+ *
+ * This generated file contains a sample Java application project to get you started.
+ * For more details on building Java & JVM projects, please refer to https://docs.gradle.org/8.8/userguide/building_java_projects.html in the Gradle documentation.
+ */
+
+plugins {
+    // Apply the application plugin to add support for building a CLI application in Java.
+    id 'application'
+}
+
+repositories {
+    // Use Maven Central for resolving dependencies.
+    mavenCentral()
+}
+
+dependencies {
+    // Use JUnit Jupiter for testing.
+    testImplementation libs.junit.jupiter
+
+    testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
+    
+    implementation libs.com.rabbitmq.client
+}
+
+// Apply a specific Java toolchain to ease working on different environments.
+java {
+    toolchain {
+        languageVersion = JavaLanguageVersion.of(21)
+    }
+}
+
+application {
+    // Define the main class for the application.
+    mainClass = 'dev.tishenko.consumer.Recv'
+}
+
+tasks.named('test') {
+    // Use JUnit Platform for unit tests.
+    useJUnitPlatform()
+}

lab3/consumer/app/src/main/java/dev/tishenko/consumer/Recv.java

@@ -0,0 +1,55 @@
+package dev.tishenko.consumer;
+
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.DeliverCallback;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class Recv {
+    private final static String QUEUE_NAME = "hello";
+
+    public static void main(String[] argv) throws Exception {
+        String delayEnv = System.getenv("CONSUMER_DELAY_MS");
+        int delay = delayEnv != null ? Integer.parseInt(delayEnv) : 5000;
+
+        String maxLengthEnv = System.getenv("QUEUE_MAX_LENGTH");
+        int maxLength = maxLengthEnv != null ? Integer.parseInt(maxLengthEnv) : 5;
+
+        String overflowStrategy = System.getenv("QUEUE_OVERFLOW");
+        if (overflowStrategy == null) {
+            overflowStrategy = "drop-head"; // или "reject-publish"
+        }
+
+        ConnectionFactory factory = new ConnectionFactory();
+        factory.setHost("rabbitmq");
+
+        Connection connection = factory.newConnection();
+        Channel channel = connection.createChannel();
+
+        Map<String, Object> args = new HashMap<>();
+        args.put("x-max-length", maxLength);
+        args.put("x-overflow", overflowStrategy);
+
+        channel.queueDeclare(QUEUE_NAME, false, false, false, args);
+        channel.basicQos(1);
+
+        System.out.println(" [*] Waiting for messages...");
+
+        DeliverCallback deliverCallback = (consumerTag, delivery) -> {
+            String message = new String(delivery.getBody(), "UTF-8");
+            System.out.println(" [x] Received '" + message + "'");
+            try {
+                Thread.sleep(delay);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+            channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
+        };
+
+        channel.basicConsume(QUEUE_NAME, false, deliverCallback, consumerTag -> {
+        });
+    }
+}

lab3/consumer/gradle/libs.versions.toml

@@ -0,0 +1,10 @@
+# This file was generated by the Gradle 'init' task.
+# https://docs.gradle.org/current/userguide/platforms.html#sub::toml-dependencies-format
+
+[versions]
+junit-jupiter = "5.10.2"
+com-rabbitmq-client = "5.25.0"
+
+[libraries]
+junit-jupiter = { module = "org.junit.jupiter:junit-jupiter", version.ref = "junit-jupiter" }
+com-rabbitmq-client = { module = "com.rabbitmq:amqp-client", version.ref = "com-rabbitmq-client"}

lab3/consumer/gradle/wrapper/gradle-wrapper.properties

@@ -0,0 +1,7 @@
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.8-bin.zip
+networkTimeout=10000
+validateDistributionUrl=true
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists

lab3/consumer/gradlew

@@ -0,0 +1,249 @@
+#!/bin/sh
+
+#
+# Copyright © 2015-2021 the original authors.
+#
+# Licensed 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
+#
+#      https://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.
+#
+
+##############################################################################
+#
+#   Gradle start up script for POSIX generated by Gradle.
+#
+#   Important for running:
+#
+#   (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
+#       noncompliant, but you have some other compliant shell such as ksh or
+#       bash, then to run this script, type that shell name before the whole
+#       command line, like:
+#
+#           ksh Gradle
+#
+#       Busybox and similar reduced shells will NOT work, because this script
+#       requires all of these POSIX shell features:
+#         * functions;
+#         * expansions «$var», «${var}», «${var:-default}», «${var+SET}»,
+#           «${var#prefix}», «${var%suffix}», and «$( cmd )»;
+#         * compound commands having a testable exit status, especially «case»;
+#         * various built-in commands including «command», «set», and «ulimit».
+#
+#   Important for patching:
+#
+#   (2) This script targets any POSIX shell, so it avoids extensions provided
+#       by Bash, Ksh, etc; in particular arrays are avoided.
+#
+#       The "traditional" practice of packing multiple parameters into a
+#       space-separated string is a well documented source of bugs and security
+#       problems, so this is (mostly) avoided, by progressively accumulating
+#       options in "$@", and eventually passing that to Java.
+#
+#       Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
+#       and GRADLE_OPTS) rely on word-splitting, this is performed explicitly;
+#       see the in-line comments for details.
+#
+#       There are tweaks for specific operating systems such as AIX, CygWin,
+#       Darwin, MinGW, and NonStop.
+#
+#   (3) This script is generated from the Groovy template
+#       https://github.com/gradle/gradle/blob/HEAD/platforms/jvm/plugins-application/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
+#       within the Gradle project.
+#
+#       You can find Gradle at https://github.com/gradle/gradle/.
+#
+##############################################################################
+
+# Attempt to set APP_HOME
+
+# Resolve links: $0 may be a link
+app_path=$0
+
+# Need this for daisy-chained symlinks.
+while
+    APP_HOME=${app_path%"${app_path##*/}"}  # leaves a trailing /; empty if no leading path
+    [ -h "$app_path" ]
+do
+    ls=$( ls -ld "$app_path" )
+    link=${ls#*' -> '}
+    case $link in             #(
+      /*)   app_path=$link ;; #(
+      *)    app_path=$APP_HOME$link ;;
+    esac
+done
+
+# This is normally unused
+# shellcheck disable=SC2034
+APP_BASE_NAME=${0##*/}
+# Discard cd standard output in case $CDPATH is set (https://github.com/gradle/gradle/issues/25036)
+APP_HOME=$( cd "${APP_HOME:-./}" > /dev/null && pwd -P ) || exit
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD=maximum
+
+warn () {
+    echo "$*"
+} >&2
+
+die () {
+    echo
+    echo "$*"
+    echo
+    exit 1
+} >&2
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "$( uname )" in                #(
+  CYGWIN* )         cygwin=true  ;; #(
+  Darwin* )         darwin=true  ;; #(
+  MSYS* | MINGW* )  msys=true    ;; #(
+  NONSTOP* )        nonstop=true ;;
+esac
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD=$JAVA_HOME/jre/sh/java
+    else
+        JAVACMD=$JAVA_HOME/bin/java
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD=java
+    if ! command -v java >/dev/null 2>&1
+    then
+        die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+fi
+
+# Increase the maximum file descriptors if we can.
+if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
+    case $MAX_FD in #(
+      max*)
+        # In POSIX sh, ulimit -H is undefined. That's why the result is checked to see if it worked.
+        # shellcheck disable=SC2039,SC3045
+        MAX_FD=$( ulimit -H -n ) ||
+            warn "Could not query maximum file descriptor limit"
+    esac
+    case $MAX_FD in  #(
+      '' | soft) :;; #(
+      *)
+        # In POSIX sh, ulimit -n is undefined. That's why the result is checked to see if it worked.
+        # shellcheck disable=SC2039,SC3045
+        ulimit -n "$MAX_FD" ||
+            warn "Could not set maximum file descriptor limit to $MAX_FD"
+    esac
+fi
+
+# Collect all arguments for the java command, stacking in reverse order:
+#   * args from the command line
+#   * the main class name
+#   * -classpath
+#   * -D...appname settings
+#   * --module-path (only if needed)
+#   * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables.
+
+# For Cygwin or MSYS, switch paths to Windows format before running java
+if "$cygwin" || "$msys" ; then
+    APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
+    CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
+
+    JAVACMD=$( cygpath --unix "$JAVACMD" )
+
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    for arg do
+        if
+            case $arg in                                #(
+              -*)   false ;;                            # don't mess with options #(
+              /?*)  t=${arg#/} t=/${t%%/*}              # looks like a POSIX filepath
+                    [ -e "$t" ] ;;                      #(
+              *)    false ;;
+            esac
+        then
+            arg=$( cygpath --path --ignore --mixed "$arg" )
+        fi
+        # Roll the args list around exactly as many times as the number of
+        # args, so each arg winds up back in the position where it started, but
+        # possibly modified.
+        #
+        # NB: a `for` loop captures its iteration list before it begins, so
+        # changing the positional parameters here affects neither the number of
+        # iterations, nor the values presented in `arg`.
+        shift                   # remove old arg
+        set -- "$@" "$arg"      # push replacement arg
+    done
+fi
+
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
+
+# Collect all arguments for the java command:
+#   * DEFAULT_JVM_OPTS, JAVA_OPTS, JAVA_OPTS, and optsEnvironmentVar are not allowed to contain shell fragments,
+#     and any embedded shellness will be escaped.
+#   * For example: A user cannot expect ${Hostname} to be expanded, as it is an environment variable and will be
+#     treated as '${Hostname}' itself on the command line.
+
+set -- \
+        "-Dorg.gradle.appname=$APP_BASE_NAME" \
+        -classpath "$CLASSPATH" \
+        org.gradle.wrapper.GradleWrapperMain \
+        "$@"
+
+# Stop when "xargs" is not available.
+if ! command -v xargs >/dev/null 2>&1
+then
+    die "xargs is not available"
+fi
+
+# Use "xargs" to parse quoted args.
+#
+# With -n1 it outputs one arg per line, with the quotes and backslashes removed.
+#
+# In Bash we could simply go:
+#
+#   readarray ARGS < <( xargs -n1 <<<"$var" ) &&
+#   set -- "${ARGS[@]}" "$@"
+#
+# but POSIX shell has neither arrays nor command substitution, so instead we
+# post-process each arg (as a line of input to sed) to backslash-escape any
+# character that might be a shell metacharacter, then use eval to reverse
+# that process (while maintaining the separation between arguments), and wrap
+# the whole thing up as a single "set" statement.
+#
+# This will of course break if any of these variables contains a newline or
+# an unmatched quote.
+#
+
+eval "set -- $(
+        printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" |
+        xargs -n1 |
+        sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
+        tr '\n' ' '
+    )" '"$@"'
+
+exec "$JAVACMD" "$@"

lab3/consumer/gradlew.bat

@@ -0,0 +1,92 @@
+@rem
+@rem Copyright 2015 the original author or authors.
+@rem
+@rem Licensed under the Apache License, Version 2.0 (the "License");
+@rem you may not use this file except in compliance with the License.
+@rem You may obtain a copy of the License at
+@rem
+@rem      https://www.apache.org/licenses/LICENSE-2.0
+@rem
+@rem Unless required by applicable law or agreed to in writing, software
+@rem distributed under the License is distributed on an "AS IS" BASIS,
+@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+@rem See the License for the specific language governing permissions and
+@rem limitations under the License.
+@rem
+
+@if "%DEBUG%"=="" @echo off
+@rem ##########################################################################
+@rem
+@rem  Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%"=="" set DIRNAME=.
+@rem This is normally unused
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Resolve any "." and ".." in APP_HOME to make it shorter.
+for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if %ERRORLEVEL% equ 0 goto execute
+
+echo. 1>&2
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. 1>&2
+echo. 1>&2
+echo Please set the JAVA_HOME variable in your environment to match the 1>&2
+echo location of your Java installation. 1>&2
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto execute
+
+echo. 1>&2
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% 1>&2
+echo. 1>&2
+echo Please set the JAVA_HOME variable in your environment to match the 1>&2
+echo location of your Java installation. 1>&2
+
+goto fail
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
+
+:end
+@rem End local scope for the variables with windows NT shell
+if %ERRORLEVEL% equ 0 goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+set EXIT_CODE=%ERRORLEVEL%
+if %EXIT_CODE% equ 0 set EXIT_CODE=1
+if not ""=="%GRADLE_EXIT_CONSOLE%" exit %EXIT_CODE%
+exit /b %EXIT_CODE%
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega

lab3/consumer/settings.gradle

@@ -0,0 +1,14 @@
+/*
+ * This file was generated by the Gradle 'init' task.
+ *
+ * The settings file is used to specify which projects to include in your build.
+ * For more detailed information on multi-project builds, please refer to https://docs.gradle.org/8.8/userguide/multi_project_builds.html in the Gradle documentation.
+ */
+
+plugins {
+    // Apply the foojay-resolver plugin to allow automatic download of JDKs
+    id 'org.gradle.toolchains.foojay-resolver-convention' version '0.8.0'
+}
+
+rootProject.name = 'consumer'
+include('app')

lab3/docker-compose.yml

@@ -0,0 +1,53 @@
+services:
+  rabbitmq:
+    image: rabbitmq:4.0-management
+    hostname: rabbitmq
+    container_name: rabbitmq
+    ports:
+      - "5672:5672"
+      - "15672:15672"
+    networks:
+      - rabbitnet
+      
+  producer1:
+    container_name: producer1
+    build:
+      context: ./producer
+    depends_on:
+      - rabbitmq
+      - consumer
+    environment:
+      - PRODUCER_NAME=first
+      - PRODUCER_DELAY_MS=1000
+    networks:
+      - rabbitnet
+
+  producer2:
+    container_name: producer2
+    build:
+      context: ./producer
+    depends_on:
+      - rabbitmq
+      - consumer
+    environment:
+      - PRODUCER_NAME=second
+      - PRODUCER_DELAY_MS=1000
+    networks:
+      - rabbitnet
+
+  consumer:
+    container_name: consumer
+    build:
+      context: ./consumer
+    depends_on:
+      - rabbitmq
+    environment:
+      - CONSUMER_DELAY_MS=1000
+      - QUEUE_MAX_LENGTH=10
+      - QUEUE_OVERFLOW=reject-publish # drop-head, reject-publish
+    networks:
+      - rabbitnet
+
+networks:
+  rabbitnet:
+    driver: bridge

lab3/my-variant.txt

@@ -0,0 +1,8 @@
+Используя docker создать контейнеры, необходимые для реализации 
+следующего функционала с использованием RabbitMQ/Kafka, 
+а также показать, как именно осуществляется передача в этих условиях:
+
+10.	Организовать отправку сообщений от двух отправителей одному получателю, 
+получатель читает сообщения значительно реже их отправки 
+и происходит переполнение очереди. Задавать раличные стратегии 
+переполнения очереди, показать в чем разница.

lab3/producer/.gitattributes

@@ -0,0 +1,9 @@
+#
+# https://help.github.com/articles/dealing-with-line-endings/
+#
+# Linux start script should use lf
+/gradlew        text eol=lf
+
+# These are Windows script files and should use crlf
+*.bat           text eol=crlf
+

lab3/producer/.gitignore

@@ -0,0 +1,5 @@
+# Ignore Gradle project-specific cache directory
+.gradle
+
+# Ignore Gradle build output directory
+build

lab3/producer/.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+    "java.configuration.updateBuildConfiguration": "interactive"
+}

lab3/producer/Dockerfile

@@ -0,0 +1,9 @@
+FROM gradle:8.13-jdk21
+
+WORKDIR /app
+
+COPY . .
+
+RUN gradle build --no-daemon
+
+CMD ["gradle", "run", "--no-daemon"]

lab3/producer/app/build.gradle

@@ -0,0 +1,42 @@
+/*
+ * This file was generated by the Gradle 'init' task.
+ *
+ * This generated file contains a sample Java application project to get you started.
+ * For more details on building Java & JVM projects, please refer to https://docs.gradle.org/8.8/userguide/building_java_projects.html in the Gradle documentation.
+ */
+
+plugins {
+    // Apply the application plugin to add support for building a CLI application in Java.
+    id 'application'
+}
+
+repositories {
+    // Use Maven Central for resolving dependencies.
+    mavenCentral()
+}
+
+dependencies {
+    // Use JUnit Jupiter for testing.
+    testImplementation libs.junit.jupiter
+
+    testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
+    
+    implementation libs.com.rabbitmq.client
+}
+
+// Apply a specific Java toolchain to ease working on different environments.
+java {
+    toolchain {
+        languageVersion = JavaLanguageVersion.of(21)
+    }
+}
+
+application {
+    // Define the main class for the application.
+    mainClass = 'dev.tishenko.producer.Send'
+}
+
+tasks.named('test') {
+    // Use JUnit Platform for unit tests.
+    useJUnitPlatform()
+}

lab3/producer/app/src/main/java/dev/tishenko/producer/Send.java

@@ -0,0 +1,38 @@
+package dev.tishenko.producer;
+
+import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.Channel;
+
+public class Send {
+    private static final String QUEUE_NAME = "hello";
+
+    public static void main(String[] args) throws Exception {
+        String name = System.getenv("PRODUCER_NAME");
+        name = name != null ? name : "";
+
+        String delayEnv = System.getenv("PRODUCER_DELAY_MS");
+        int delay = delayEnv != null ? Integer.parseInt(delayEnv) : 1000;
+
+        ConnectionFactory factory = new ConnectionFactory();
+        factory.setHost("rabbitmq");
+
+        try (Connection connection = factory.newConnection();
+                Channel channel = connection.createChannel()) {
+            channel.queueDeclarePassive(QUEUE_NAME);
+            channel.confirmSelect();
+
+            int count = 0;
+            while (true) {
+                String message = "Message from " + name + " #" + count++;
+                channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
+                if (!channel.waitForConfirms()) {
+                    System.out.println(" [!] Message was NOT confirmed!");
+                } else {
+                    System.out.println(" [x] Sent '" + message + "'");
+                }
+                Thread.sleep(delay);
+            }
+        }
+    }
+}

lab3/producer/gradle/libs.versions.toml

@@ -0,0 +1,10 @@
+# This file was generated by the Gradle 'init' task.
+# https://docs.gradle.org/current/userguide/platforms.html#sub::toml-dependencies-format
+
+[versions]
+junit-jupiter = "5.10.2"
+com-rabbitmq-client = "5.25.0"
+
+[libraries]
+junit-jupiter = { module = "org.junit.jupiter:junit-jupiter", version.ref = "junit-jupiter" }
+com-rabbitmq-client = { module = "com.rabbitmq:amqp-client", version.ref = "com-rabbitmq-client"}

lab3/producer/gradle/wrapper/gradle-wrapper.properties

@@ -0,0 +1,7 @@
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.8-bin.zip
+networkTimeout=10000
+validateDistributionUrl=true
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists

lab3/producer/gradlew

@@ -0,0 +1,249 @@
+#!/bin/sh
+
+#
+# Copyright © 2015-2021 the original authors.
+#
+# Licensed 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
+#
+#      https://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.
+#
+
+##############################################################################
+#
+#   Gradle start up script for POSIX generated by Gradle.
+#
+#   Important for running:
+#
+#   (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
+#       noncompliant, but you have some other compliant shell such as ksh or
+#       bash, then to run this script, type that shell name before the whole
+#       command line, like:
+#
+#           ksh Gradle
+#
+#       Busybox and similar reduced shells will NOT work, because this script
+#       requires all of these POSIX shell features:
+#         * functions;
+#         * expansions «$var», «${var}», «${var:-default}», «${var+SET}»,
+#           «${var#prefix}», «${var%suffix}», and «$( cmd )»;
+#         * compound commands having a testable exit status, especially «case»;
+#         * various built-in commands including «command», «set», and «ulimit».
+#
+#   Important for patching:
+#
+#   (2) This script targets any POSIX shell, so it avoids extensions provided
+#       by Bash, Ksh, etc; in particular arrays are avoided.
+#
+#       The "traditional" practice of packing multiple parameters into a
+#       space-separated string is a well documented source of bugs and security
+#       problems, so this is (mostly) avoided, by progressively accumulating
+#       options in "$@", and eventually passing that to Java.
+#
+#       Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
+#       and GRADLE_OPTS) rely on word-splitting, this is performed explicitly;
+#       see the in-line comments for details.
+#
+#       There are tweaks for specific operating systems such as AIX, CygWin,
+#       Darwin, MinGW, and NonStop.
+#
+#   (3) This script is generated from the Groovy template
+#       https://github.com/gradle/gradle/blob/HEAD/platforms/jvm/plugins-application/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
+#       within the Gradle project.
+#
+#       You can find Gradle at https://github.com/gradle/gradle/.
+#
+##############################################################################
+
+# Attempt to set APP_HOME
+
+# Resolve links: $0 may be a link
+app_path=$0
+
+# Need this for daisy-chained symlinks.
+while
+    APP_HOME=${app_path%"${app_path##*/}"}  # leaves a trailing /; empty if no leading path
+    [ -h "$app_path" ]
+do
+    ls=$( ls -ld "$app_path" )
+    link=${ls#*' -> '}
+    case $link in             #(
+      /*)   app_path=$link ;; #(
+      *)    app_path=$APP_HOME$link ;;
+    esac
+done
+
+# This is normally unused
+# shellcheck disable=SC2034
+APP_BASE_NAME=${0##*/}
+# Discard cd standard output in case $CDPATH is set (https://github.com/gradle/gradle/issues/25036)
+APP_HOME=$( cd "${APP_HOME:-./}" > /dev/null && pwd -P ) || exit
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD=maximum
+
+warn () {
+    echo "$*"
+} >&2
+
+die () {
+    echo
+    echo "$*"
+    echo
+    exit 1
+} >&2
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "$( uname )" in                #(
+  CYGWIN* )         cygwin=true  ;; #(
+  Darwin* )         darwin=true  ;; #(
+  MSYS* | MINGW* )  msys=true    ;; #(
+  NONSTOP* )        nonstop=true ;;
+esac
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD=$JAVA_HOME/jre/sh/java
+    else
+        JAVACMD=$JAVA_HOME/bin/java
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD=java
+    if ! command -v java >/dev/null 2>&1
+    then
+        die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+fi
+
+# Increase the maximum file descriptors if we can.
+if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
+    case $MAX_FD in #(
+      max*)
+        # In POSIX sh, ulimit -H is undefined. That's why the result is checked to see if it worked.
+        # shellcheck disable=SC2039,SC3045
+        MAX_FD=$( ulimit -H -n ) ||
+            warn "Could not query maximum file descriptor limit"
+    esac
+    case $MAX_FD in  #(
+      '' | soft) :;; #(
+      *)
+        # In POSIX sh, ulimit -n is undefined. That's why the result is checked to see if it worked.
+        # shellcheck disable=SC2039,SC3045
+        ulimit -n "$MAX_FD" ||
+            warn "Could not set maximum file descriptor limit to $MAX_FD"
+    esac
+fi
+
+# Collect all arguments for the java command, stacking in reverse order:
+#   * args from the command line
+#   * the main class name
+#   * -classpath
+#   * -D...appname settings
+#   * --module-path (only if needed)
+#   * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables.
+
+# For Cygwin or MSYS, switch paths to Windows format before running java
+if "$cygwin" || "$msys" ; then
+    APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
+    CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
+
+    JAVACMD=$( cygpath --unix "$JAVACMD" )
+
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    for arg do
+        if
+            case $arg in                                #(
+              -*)   false ;;                            # don't mess with options #(
+              /?*)  t=${arg#/} t=/${t%%/*}              # looks like a POSIX filepath
+                    [ -e "$t" ] ;;                      #(
+              *)    false ;;
+            esac
+        then
+            arg=$( cygpath --path --ignore --mixed "$arg" )
+        fi
+        # Roll the args list around exactly as many times as the number of
+        # args, so each arg winds up back in the position where it started, but
+        # possibly modified.
+        #
+        # NB: a `for` loop captures its iteration list before it begins, so
+        # changing the positional parameters here affects neither the number of
+        # iterations, nor the values presented in `arg`.
+        shift                   # remove old arg
+        set -- "$@" "$arg"      # push replacement arg
+    done
+fi
+
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
+
+# Collect all arguments for the java command:
+#   * DEFAULT_JVM_OPTS, JAVA_OPTS, JAVA_OPTS, and optsEnvironmentVar are not allowed to contain shell fragments,
+#     and any embedded shellness will be escaped.
+#   * For example: A user cannot expect ${Hostname} to be expanded, as it is an environment variable and will be
+#     treated as '${Hostname}' itself on the command line.
+
+set -- \
+        "-Dorg.gradle.appname=$APP_BASE_NAME" \
+        -classpath "$CLASSPATH" \
+        org.gradle.wrapper.GradleWrapperMain \
+        "$@"
+
+# Stop when "xargs" is not available.
+if ! command -v xargs >/dev/null 2>&1
+then
+    die "xargs is not available"
+fi
+
+# Use "xargs" to parse quoted args.
+#
+# With -n1 it outputs one arg per line, with the quotes and backslashes removed.
+#
+# In Bash we could simply go:
+#
+#   readarray ARGS < <( xargs -n1 <<<"$var" ) &&
+#   set -- "${ARGS[@]}" "$@"
+#
+# but POSIX shell has neither arrays nor command substitution, so instead we
+# post-process each arg (as a line of input to sed) to backslash-escape any
+# character that might be a shell metacharacter, then use eval to reverse
+# that process (while maintaining the separation between arguments), and wrap
+# the whole thing up as a single "set" statement.
+#
+# This will of course break if any of these variables contains a newline or
+# an unmatched quote.
+#
+
+eval "set -- $(
+        printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" |
+        xargs -n1 |
+        sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
+        tr '\n' ' '
+    )" '"$@"'
+
+exec "$JAVACMD" "$@"

lab3/producer/gradlew.bat

@@ -0,0 +1,92 @@
+@rem
+@rem Copyright 2015 the original author or authors.
+@rem
+@rem Licensed under the Apache License, Version 2.0 (the "License");
+@rem you may not use this file except in compliance with the License.
+@rem You may obtain a copy of the License at
+@rem
+@rem      https://www.apache.org/licenses/LICENSE-2.0
+@rem
+@rem Unless required by applicable law or agreed to in writing, software
+@rem distributed under the License is distributed on an "AS IS" BASIS,
+@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+@rem See the License for the specific language governing permissions and
+@rem limitations under the License.
+@rem
+
+@if "%DEBUG%"=="" @echo off
+@rem ##########################################################################
+@rem
+@rem  Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%"=="" set DIRNAME=.
+@rem This is normally unused
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Resolve any "." and ".." in APP_HOME to make it shorter.
+for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if %ERRORLEVEL% equ 0 goto execute
+
+echo. 1>&2
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. 1>&2
+echo. 1>&2
+echo Please set the JAVA_HOME variable in your environment to match the 1>&2
+echo location of your Java installation. 1>&2
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto execute
+
+echo. 1>&2
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% 1>&2
+echo. 1>&2
+echo Please set the JAVA_HOME variable in your environment to match the 1>&2
+echo location of your Java installation. 1>&2
+
+goto fail
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
+
+:end
+@rem End local scope for the variables with windows NT shell
+if %ERRORLEVEL% equ 0 goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+set EXIT_CODE=%ERRORLEVEL%
+if %EXIT_CODE% equ 0 set EXIT_CODE=1
+if not ""=="%GRADLE_EXIT_CONSOLE%" exit %EXIT_CODE%
+exit /b %EXIT_CODE%
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega

lab3/producer/settings.gradle

@@ -0,0 +1,14 @@
+/*
+ * This file was generated by the Gradle 'init' task.
+ *
+ * The settings file is used to specify which projects to include in your build.
+ * For more detailed information on multi-project builds, please refer to https://docs.gradle.org/8.8/userguide/multi_project_builds.html in the Gradle documentation.
+ */
+
+plugins {
+    // Apply the foojay-resolver plugin to allow automatic download of JDKs
+    id 'org.gradle.toolchains.foojay-resolver-convention' version '0.8.0'
+}
+
+rootProject.name = 'producer'
+include('app')

lab3/report/.gitignore

@@ -0,0 +1,5 @@
+**/*
+!.gitignore
+!report.tex
+!img
+!img/**

lab3/report/report.tex

@@ -0,0 +1,464 @@
+\documentclass[a4paper, final]{article}
+%\usepackage{literat} % Нормальные шрифты
+\usepackage[14pt]{extsizes} % для того чтобы задать нестандартный 14-ый размер шрифта
+\usepackage{tabularx}
+\usepackage[T2A]{fontenc}
+\usepackage[utf8]{inputenc}
+\usepackage[russian]{babel}
+\usepackage{amsmath}
+\usepackage[left=25mm, top=20mm, right=20mm, bottom=20mm, footskip=10mm]{geometry}
+\usepackage{ragged2e} %для растягивания по ширине
+\usepackage{setspace} %для межстрочно   го интервала
+\usepackage{moreverb} %для работы с листингами
+\usepackage{indentfirst} % для абзацного отступа
+\usepackage{moreverb} %для печати в листинге исходного кода программ
+\usepackage{pdfpages} %для вставки других pdf файлов
+\usepackage{tikz}
+\usepackage{graphicx}
+\usepackage{afterpage}
+\usepackage{longtable}
+\usepackage{float}
+\usepackage{tabularx}
+
+
+
+% \usepackage[paper=A4,DIV=12]{typearea}
+\usepackage{pdflscape}
+% \usepackage{lscape}
+
+\usepackage{array}
+\usepackage{multirow}
+
+\renewcommand\verbatimtabsize{4\relax}
+\renewcommand\listingoffset{0.2em} %отступ от номеров строк в листинге
+\renewcommand{\arraystretch}{1.4} % изменяю высоту строки в таблице
+\usepackage[font=small, singlelinecheck=false, justification=centering, format=plain, labelsep=period]{caption} %для настройки заголовка таблицы
+\usepackage{listings} %листинги
+\usepackage{xcolor} % цвета
+\usepackage{hyperref}% для гиперссылок
+\usepackage{enumitem} %для перечислений
+
+\newcommand{\specialcell}[2][l]{\begin{tabular}[#1]{@{}l@{}}#2\end{tabular}}
+
+
+\setlist[enumerate,itemize]{leftmargin=1.2cm} %отступ в перечислениях
+
+\hypersetup{colorlinks,
+    allcolors=[RGB]{010 090 200}} %красивые гиперссылки (не красные)
+
+% подгружаемые языки — подробнее в документации listings (это всё для листингов)
+\lstloadlanguages{ SQL}
+% включаем кириллицу и добавляем кое−какие опции
+\lstset{tabsize=2,
+    breaklines,
+    basicstyle=\footnotesize,
+    columns=fullflexible,
+    flexiblecolumns,
+    numbers=left,
+    numberstyle={\footnotesize},
+    keywordstyle=\color{blue},
+    inputencoding=cp1251,
+    extendedchars=true
+}
+\lstdefinelanguage{MyC}{
+    language=SQL,
+%    ndkeywordstyle=\color{darkgray}\bfseries,
+%    identifierstyle=\color{black},
+%    morecomment=[n]{/**}{*/},
+%    commentstyle=\color{blue}\ttfamily,
+%    stringstyle=\color{red}\ttfamily,
+%    morestring=[b]",
+%    showstringspaces=false,
+%    morecomment=[l][\color{gray}]{//},
+    keepspaces=true,
+    escapechar=\%,
+    texcl=true
+}
+
+\textheight=24cm % высота текста
+\textwidth=16cm % ширина текста
+\oddsidemargin=0pt % отступ от левого края
+\topmargin=-1.5cm % отступ от верхнего края
+\parindent=24pt % абзацный отступ
+\parskip=5pt % интервал между абзацами
+\tolerance=2000 % терпимость к "жидким" строкам
+\flushbottom % выравнивание высоты страниц
+
+
+% Настройка листингов
+\lstset{
+    language=C++,
+    extendedchars=\true,
+    inputencoding=utf8,
+    keepspaces=true,
+    % captionpos=b, % подписи листингов снизу
+}
+
+\begin{document} % начало документа
+    
+
+
+    % НАЧАЛО ТИТУЛЬНОГО ЛИСТА
+    \begin{center}
+        \hfill \break
+        \hfill \break
+        \normalsize{МИНИСТЕРСТВО НАУКИ И ВЫСШЕГО ОБРАЗОВАНИЯ РОССИЙСКОЙ ФЕДЕРАЦИИ\\
+            федеральное государственное автономное образовательное учреждение высшего образования «Санкт-Петербургский политехнический университет Петра Великого»\\[10pt]}
+        \normalsize{Институт компьютерных наук и кибербезопасности}\\[10pt] 
+        \normalsize{Высшая школа технологий искусственного интеллекта}\\[10pt] 
+        \normalsize{Направление: 02.03.01 <<Математика и компьютерные науки>>}\\
+        
+        \hfill \break
+        \hfill \break
+        \hfill \break
+        \hfill \break
+        \large{Лабораторная работа №3}\\
+        \large{<<Межпроцессорное взаимодействие с помощью  RabbitMQ>>}\\
+        \large{по дисциплине <<Сети ЭВМ и телекоммуникации компьютерных сетей>>}\\
+        \hfill \break
+        
+        % \hfill \break
+        \hfill \break
+    \end{center}
+    
+    \small{ 
+        \begin{tabular}{lrrl}
+            \!\!\!Студент, & \hspace{2cm} & & \\
+            \!\!\!группы 5130201/20102 & \hspace{2cm} & \underline{\hspace{3cm}} &Тищенко А. А. \\\\
+            \!\!\!Преподаватель & \hspace{2cm} &  \underline{\hspace{3cm}} &  Мулюха В. А. \\\\
+            &&\hspace{4cm}
+        \end{tabular}
+        \begin{flushright}
+            <<\underline{\hspace{1cm}}>>\underline{\hspace{2.5cm}} 2025г.
+        \end{flushright}
+    }
+    
+    \hfill \break
+    % \hfill \break
+    \begin{center} \small{Санкт-Петербург, 2025} \end{center}
+    \thispagestyle{empty} % выключаем отображение номера для этой страницы
+    
+    % КОНЕЦ ТИТУЛЬНОГО ЛИСТА
+    % \newpage
+    % \tableofcontents
+
+
+    \newpage
+    \section{Постановка задачи}
+    Используя docker создать контейнеры, необходимые для реализации 
+    следующего функционала с использованием RabbitMQ, 
+    а также показать, как именно осуществляется передача в этих условиях:
+    
+    \textit{Вариант 10}. Организовать отправку сообщений от двух отправителей одному получателю, 
+    получатель читает сообщения значительно реже их отправки 
+    и происходит переполнение очереди. Задавать раличные стратегии 
+    переполнения очереди, показать в чем разница.
+    
+
+    \newpage
+    \section{Ход работы}
+
+\subsection{Код программы получателя}
+Класс `Recv` из пакета `dev.tishenko.consumer` реализует потребителя сообщений из очереди RabbitMQ с именем `hello`. Он подключается к брокеру `rabbitmq`, создаёт очередь с ограниченной длиной (`x-max-length`) и стратегией переполнения (`x-overflow`), параметры которых настраиваются через переменные окружения. Консьюмер асинхронно принимает сообщения и после каждой обработки (с задержкой, заданной через `CONSUMER\_DELAY\_MS`) подтверждает получение сообщения. Благодаря настройке `basicQos(1)` сообщения обрабатываются по одному, что обеспечивает контроль нагрузки и предотвращает переполнение очереди необработанными сообщениями.
+
+\begin{lstlisting}[label={lst:}]
+package dev.tishenko.consumer;
+
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.DeliverCallback;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class Recv {
+    private final static String QUEUE_NAME = "hello";
+
+    public static void main(String[] argv) throws Exception {
+        String delayEnv = System.getenv("CONSUMER_DELAY_MS");
+        int delay = delayEnv != null ? Integer.parseInt(delayEnv) : 5000;
+
+        String maxLengthEnv = System.getenv("QUEUE_MAX_LENGTH");
+        int maxLength = maxLengthEnv != null ? Integer.parseInt(maxLengthEnv) : 5;
+
+        String overflowStrategy = System.getenv("QUEUE_OVERFLOW");
+        if (overflowStrategy == null) {
+            overflowStrategy = "drop-head"; // или "reject-publish"
+        }
+
+        ConnectionFactory factory = new ConnectionFactory();
+        factory.setHost("rabbitmq");
+
+        Connection connection = factory.newConnection();
+        Channel channel = connection.createChannel();
+
+        Map<String, Object> args = new HashMap<>();
+        args.put("x-max-length", maxLength);
+        args.put("x-overflow", overflowStrategy);
+
+        channel.queueDeclare(QUEUE_NAME, false, false, false, args);
+        channel.basicQos(1);
+
+        System.out.println(" [*] Waiting for messages...");
+
+        DeliverCallback deliverCallback = (consumerTag, delivery) -> {
+            String message = new String(delivery.getBody(), "UTF-8");
+            System.out.println(" [x] Received '" + message + "'");
+            try {
+                Thread.sleep(delay);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+            channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
+        };
+
+        channel.basicConsume(QUEUE_NAME, false, deliverCallback, consumerTag -> {
+        });
+    }
+}
+\end{lstlisting}
+
+
+    \subsection{Код программы отправителя}
+
+    Класс `Send` представляет собой простого отправителя сообщений для RabbitMQ. Он подключается к брокеру (по адресу контейнера `rabbitmq`), использует очередь с именем `hello` (предполагая, что она уже существует), и в бесконечном цикле отправляет в неё сообщения с уникальным номером, указывая имя продюсера, полученное из переменной окружения `PRODUCER\_NAME`. Задержка между отправками настраивается через переменную `PRODUCER\_DELAY\_MS`. После каждой отправки ожидается подтверждение от брокера, иначе выводится предупреждение.
+
+\begin{lstlisting}[label={lst:}]
+package dev.tishenko.producer;
+
+import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.Channel;
+
+public class Send {
+    private static final String QUEUE_NAME = "hello";
+
+    public static void main(String[] args) throws Exception {
+        String name = System.getenv("PRODUCER_NAME");
+        name = name != null ? name : "";
+
+        String delayEnv = System.getenv("PRODUCER_DELAY_MS");
+        int delay = delayEnv != null ? Integer.parseInt(delayEnv) : 1000;
+
+        ConnectionFactory factory = new ConnectionFactory();
+        factory.setHost("rabbitmq");
+
+        try (Connection connection = factory.newConnection();
+                Channel channel = connection.createChannel()) {
+            channel.queueDeclarePassive(QUEUE_NAME);
+            channel.confirmSelect();
+
+            int count = 0;
+            while (true) {
+                String message = "Message from " + name + " #" + count++;
+                channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
+                if (!channel.waitForConfirms()) {
+                    System.out.println(" [!] Message was NOT confirmed!");
+                } else {
+                    System.out.println(" [x] Sent '" + message + "'");
+                }
+                Thread.sleep(delay);
+            }
+        }
+    }
+}
+\end{lstlisting}
+
+\subsection{Dockerfile для отправителя и получателя}
+Для программы отправителя и получателя сообщений были созданы два идентичных Dockerfile. Программы написаны на Java и собирались с помощью Gradle, поэтому используется базовый образ \texttt{gradle:8.13-jdk21}.
+
+\begin{lstlisting}[label={lst:}]
+FROM gradle:8.13-jdk21
+
+WORKDIR /app
+
+COPY . .
+
+RUN gradle build --no-daemon
+
+CMD ["gradle", "run", "--no-daemon"]
+\end{lstlisting}
+
+\subsection{Настройка Docker Compose}
+Файл \texttt{docker-compose.yml} нужен, чтобы управлять сразу несколькими контейнерами. Файл, представленный ниже, состоит из следующих секций:
+\begin{itemize}
+    \item \textbf{rabbitmq} -- контейнер с RabbitMQ. Используется образ \texttt{rabbitmq:4.0-management}, который включает веб-интерфейс для мониторинга. Порты 5672 и 15672 проброшены наружу для AMQP-протокола и веб-интерфейса соответственно.
+    
+    \item \textbf{producer1} -- первый продюсер, отправляющий сообщения в RabbitMQ. Сборка производится из локальной директории \texttt{./producer}. В переменных окружения задаётся имя продюсера (\texttt{PRODUCER\_NAME}) и задержка между отправкой сообщений в миллисекундах (\texttt{PRODUCER\_DELAY\_MS}).
+    
+    \item \textbf{producer2} -- второй продюсер, аналогичный первому.
+    
+    \item \textbf{consumer} -- получатель сообщений из очереди RabbitMQ. Сборка происходит из директории \texttt{./consumer}. Консьюмер обрабатывает сообщения с заданной задержкой (\texttt{CONSUMER\_DELAY\_MS}). Дополнительно задаются параметры очереди: максимальная длина (\texttt{QUEUE\_MAX\_LENGTH}) и поведение при переполнении (\texttt{QUEUE\_OVERFLOW}).
+    
+    \item \textbf{networks} -- определение виртуальной сети \texttt{rabbitnet}, через которую все сервисы обмениваются данными. Используется стандартный сетевой драйвер \texttt{bridge}.
+\end{itemize}
+
+
+\begin{lstlisting}[label={lst:}]
+services:
+rabbitmq:
+    image: rabbitmq:4.0-management
+    hostname: rabbitmq
+    container_name: rabbitmq
+    ports:
+    - "5672:5672"
+    - "15672:15672"
+    networks:
+    - rabbitnet
+    
+producer1:
+    container_name: producer1
+    build:
+    context: ./producer
+    depends_on:
+    - rabbitmq
+    - consumer
+    environment:
+    - PRODUCER_NAME=first
+    - PRODUCER_DELAY_MS=1000
+    networks:
+    - rabbitnet
+
+producer2:
+    container_name: producer2
+    build:
+    context: ./producer
+    depends_on:
+    - rabbitmq
+    - consumer
+    environment:
+    - PRODUCER_NAME=second
+    - PRODUCER_DELAY_MS=1000
+    networks:
+    - rabbitnet
+
+consumer:
+    container_name: consumer
+    build:
+    context: ./consumer
+    depends_on:
+    - rabbitmq
+    environment:
+    - CONSUMER_DELAY_MS=1000
+    - QUEUE_MAX_LENGTH=10
+    - QUEUE_OVERFLOW=reject-publish # drop-head, reject-publish
+    networks:
+    - rabbitnet
+
+networks:
+rabbitnet:
+    driver: bridge
+\end{lstlisting}
+
+\section{Результат работы}
+
+Ниже представлены логи для 10 секунд работы контейнеров, в режиме \texttt{QUEUE\_OVERFLOW=drop-head}. Начиная с 25 строки видно, что получатель начинает получать сообщения только от первого отправителя, потому что сообщения второго просто удаляются.
+\begin{lstlisting}[label={lst:}]
+producer1  |  [x] Sent 'Message from first #0'
+producer1  |  [x] Sent 'Message from first #1'
+producer2  |  [x] Sent 'Message from second #2'
+consumer   |  [x] Received 'Message from second #1'
+producer1  |  [x] Sent 'Message from first #2'
+producer2  |  [x] Sent 'Message from second #3'
+consumer   |  [x] Received 'Message from first #1'
+producer1  |  [x] Sent 'Message from first #3'
+producer2  |  [x] Sent 'Message from second #4'
+consumer   |  [x] Received 'Message from second #2'
+producer1  |  [x] Sent 'Message from first #4'
+producer2  |  [x] Sent 'Message from second #5'
+consumer   |  [x] Received 'Message from first #2'
+producer1  |  [x] Sent 'Message from first #5'
+producer2  |  [x] Sent 'Message from second #6'
+consumer   |  [x] Received 'Message from second #3'
+producer1  |  [x] Sent 'Message from first #6'
+producer2  |  [x] Sent 'Message from second #7'
+consumer   |  [x] Received 'Message from first #3'
+producer1  |  [x] Sent 'Message from first #7'
+producer2  |  [x] Sent 'Message from second #8'
+consumer   |  [x] Received 'Message from second #4'
+producer1  |  [x] Sent 'Message from first #8'
+producer2  |  [x] Sent 'Message from second #9'
+consumer   |  [x] Received 'Message from first #4'
+producer1  |  [x] Sent 'Message from first #9'
+producer2  |  [x] Sent 'Message from second #10'
+consumer   |  [x] Received 'Message from first #5'
+producer1  |  [x] Sent 'Message from first #10'
+producer2  |  [x] Sent 'Message from second #11'
+consumer   |  [x] Received 'Message from first #6'
+producer1  |  [x] Sent 'Message from first #11'
+producer2  |  [x] Sent 'Message from second #12'
+consumer   |  [x] Received 'Message from first #7'
+producer1  |  [x] Sent 'Message from first #12'
+producer2  |  [x] Sent 'Message from second #13'
+consumer   |  [x] Received 'Message from first #8'
+producer1  |  [x] Sent 'Message from first #13'
+producer2  |  [x] Sent 'Message from second #14'
+consumer   |  [x] Received 'Message from first #9'
+producer1  |  [x] Sent 'Message from first #14'
+producer2  |  [x] Sent 'Message from second #15'
+consumer   |  [x] Received 'Message from first #10'
+\end{lstlisting}
+
+Ниже представлены логи для 10 секунд работы контейнеров, в режиме \texttt{QUEUE\_OVERFLOW=reject-publish}. Начиная с 27 строки, второй отправитель выдаёт сообщение \texttt{Message was NOT confirmed!}, это означает, что он получает отказ от RabbitMQ и его сообщение не добавляется в очередь.
+\begin{lstlisting}[label={lst:}]
+producer1  |  [x] Sent 'Message from first #0'
+producer1  |  [x] Sent 'Message from first #1'
+consumer   |  [x] Received 'Message from second #1'
+producer2  |  [x] Sent 'Message from second #2'
+producer1  |  [x] Sent 'Message from first #2'
+consumer   |  [x] Received 'Message from first #1'
+producer2  |  [x] Sent 'Message from second #3'
+producer1  |  [x] Sent 'Message from first #3'
+consumer   |  [x] Received 'Message from second #2'
+producer2  |  [x] Sent 'Message from second #4'
+producer1  |  [x] Sent 'Message from first #4'
+consumer   |  [x] Received 'Message from first #2'
+producer2  |  [x] Sent 'Message from second #5'
+producer1  |  [x] Sent 'Message from first #5'
+consumer   |  [x] Received 'Message from second #3'
+producer2  |  [x] Sent 'Message from second #6'
+producer1  |  [x] Sent 'Message from first #6'
+consumer   |  [x] Received 'Message from first #3'
+producer2  |  [x] Sent 'Message from second #7'
+producer1  |  [x] Sent 'Message from first #7'
+producer2  |  [x] Sent 'Message from second #8'
+producer1  |  [x] Sent 'Message from first #8'
+consumer   |  [x] Received 'Message from second #4'
+producer2  |  [x] Sent 'Message from second #9'
+producer1  |  [x] Sent 'Message from first #9'
+consumer   |  [x] Received 'Message from first #4'
+producer2  |  [!] Message was NOT confirmed!
+producer1  |  [x] Sent 'Message from first #10'
+consumer   |  [x] Received 'Message from second #5'
+producer2  |  [!] Message was NOT confirmed!
+producer1  |  [x] Sent 'Message from first #11'
+consumer   |  [x] Received 'Message from first #5'
+producer2  |  [!] Message was NOT confirmed!
+producer1  |  [x] Sent 'Message from first #12'
+consumer   |  [x] Received 'Message from second #6'
+producer2  |  [!] Message was NOT confirmed!
+producer1  |  [x] Sent 'Message from first #13'
+consumer   |  [x] Received 'Message from first #6'
+producer1  |  [x] Sent 'Message from first #14'
+consumer   |  [x] Received 'Message from second #7'
+producer2  |  [!] Message was NOT confirmed!
+producer1  |  [x] Sent 'Message from first #15'
+consumer   |  [x] Received 'Message from first #7'
+producer2  |  [!] Message was NOT confirmed!
+producer1  |  [x] Sent 'Message from first #16'
+consumer   |  [x] Received 'Message from second #8'
+producer2  |  [!] Message was NOT confirmed!
+producer1  |  [x] Sent 'Message from first #17'
+consumer   |  [x] Received 'Message from first #8'
+producer2  |  [!] Message was NOT confirmed!
+consumer   |  [x] Received 'Message from second #9'
+producer2  |  [!] Message was NOT confirmed!
+producer1  |  [x] Sent 'Message from first #18'   
+consumer   |  [x] Received 'Message from first #9'
+producer2  |  [!] Message was NOT confirmed!
+producer1  |  [x] Sent 'Message from first #19'
+consumer   |  [x] Received 'Message from first #10'
+\end{lstlisting}
+
+\end{document}