упаковал всё в docker-compose

lab3/.gitignore

@@ -1,9 +1,3 @@
-*
+*.jpg
-!.gitignore
+*.pdf
-!report
+*.docx
-!report/**
-!producer
-!producer/**
-!consumer
-!consumer/**
-!my-variant.txt

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/src/main/java/dev/tishenko/consumer/Recv.java

@@ -10,7 +10,7 @@ public class Recv {
 
     public static void main(String[] argv) throws Exception {
         ConnectionFactory factory = new ConnectionFactory();
-        factory.setHost("localhost");
+        factory.setHost("rabbitmq");
         Connection connection = factory.newConnection();
         Channel channel = connection.createChannel();
 

lab3/docker-compose.yml

@@ -0,0 +1,41 @@
+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
+    networks:
+      - rabbitnet
+
+  producer2:
+    container_name: producer2
+    build:
+      context: ./producer
+    depends_on:
+      - rabbitmq
+    networks:
+      - rabbitnet
+
+  consumer:
+    container_name: consumer
+    build:
+      context: ./consumer
+    depends_on:
+      - rabbitmq
+    networks:
+      - rabbitnet
+
+networks:
+  rabbitnet:
+    driver: bridge

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/src/main/java/dev/tishenko/producer/Send.java

@@ -9,7 +9,7 @@ public class Send {
 
     public static void main(String[] args) throws Exception {
         ConnectionFactory factory = new ConnectionFactory();
-        factory.setHost("localhost");
+        factory.setHost("rabbitmq");
         try (Connection connection = factory.newConnection();
                 Channel channel = connection.createChannel()) {
             channel.queueDeclare(QUEUE_NAME, false, false, false, null);