forked from Alexey/DAS_2024_1
Compare commits
1 Commits
bazunov_an
...
lazarev_an
| Author | SHA1 | Date | |
|---|---|---|---|
| 1565e49462 |
@@ -1,14 +0,0 @@
|
||||
# Используем официальный образ Go в качестве базового
|
||||
FROM golang:1.23
|
||||
|
||||
# Устанавливаем рабочую директорию
|
||||
WORKDIR /app
|
||||
|
||||
# Копируем файлы модуля
|
||||
COPY . .
|
||||
|
||||
# Сборка модуля
|
||||
RUN go build -o /bin/FileCreator
|
||||
|
||||
# Запуск модуля
|
||||
CMD ["/bin/FileCreator"]
|
||||
@@ -1 +0,0 @@
|
||||
module FileCreator
|
||||
@@ -1,92 +0,0 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"crypto/md5"
|
||||
"encoding/hex"
|
||||
"fmt"
|
||||
"math/rand"
|
||||
"os"
|
||||
"path/filepath"
|
||||
)
|
||||
|
||||
const DIR = "/var/data"
|
||||
|
||||
func Exists(name string) (bool, error) {
|
||||
_, err := os.Stat(name)
|
||||
if os.IsNotExist(err) {
|
||||
return false, nil
|
||||
}
|
||||
return err != nil, err
|
||||
}
|
||||
|
||||
func CreateDirectory(dirs string) error {
|
||||
if _, err := os.Stat(dirs); os.IsNotExist(err) {
|
||||
err := os.MkdirAll(dirs, 0664)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func CreateFileOrOpenIfExist(name string) (*os.File, error) {
|
||||
err := CreateDirectory(filepath.Dir(name))
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
exists, err := Exists(name)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if exists {
|
||||
return os.OpenFile(name, os.O_WRONLY|os.O_CREATE, 0664)
|
||||
}
|
||||
return os.Create(name)
|
||||
}
|
||||
|
||||
func CreateFileAndWriteData(filename string) error {
|
||||
file, err := CreateFileOrOpenIfExist(filename)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
lines := rand.Intn(1000) + 100
|
||||
|
||||
for i := 0; i < lines; i++ {
|
||||
randomValueForLine := rand.Intn(1_000_000)
|
||||
_, err = fmt.Fprintf(file, "%d\r\n", randomValueForLine)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
err = file.Close()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func GetMD5Hash(text string) string {
|
||||
hash := md5.Sum([]byte(text))
|
||||
return hex.EncodeToString(hash[:])
|
||||
}
|
||||
|
||||
func main() {
|
||||
for i := 0; i < 10; i++ {
|
||||
filename := fmt.Sprintf("%s/%s.txt", DIR, GetMD5Hash(fmt.Sprintf("%d", i)))
|
||||
err := CreateFileAndWriteData(filename)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
} else {
|
||||
fmt.Printf("Created file %s\n", filename)
|
||||
}
|
||||
}
|
||||
|
||||
err := CreateFileAndWriteData(DIR + "/data.txt")
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
} else {
|
||||
fmt.Printf("Created file %s\n", DIR+"/data.txt")
|
||||
}
|
||||
}
|
||||
@@ -1,14 +0,0 @@
|
||||
# Используем официальный образ Go в качестве базового
|
||||
FROM golang:1.23
|
||||
|
||||
# Устанавливаем рабочую директорию
|
||||
WORKDIR /app
|
||||
|
||||
# Копируем файлы модуля
|
||||
COPY . .
|
||||
|
||||
# Сборка модуля
|
||||
RUN go build -o /bin/FirstService
|
||||
|
||||
# Запуск модуля
|
||||
CMD ["/bin/FirstService"]
|
||||
@@ -1 +0,0 @@
|
||||
module RVIP2
|
||||
@@ -1,94 +0,0 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"os"
|
||||
)
|
||||
|
||||
// Формирует файл /var/result/data.txt так,
|
||||
// что каждая строка файла - количество символов в именах файлов из каталога /var/data.
|
||||
|
||||
const INPUT = "/var/data"
|
||||
const OUTPUT = "/data/result"
|
||||
|
||||
func GetListFilesInDirectory(directory string) ([]string, error) {
|
||||
f, err := os.Open(directory)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
return nil, err
|
||||
}
|
||||
files, err := f.Readdir(0)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
return nil, err
|
||||
}
|
||||
|
||||
var fileNames []string
|
||||
for _, file := range files {
|
||||
fileName := file.Name()
|
||||
fileNames = append(fileNames, fileName)
|
||||
}
|
||||
return fileNames, nil
|
||||
}
|
||||
|
||||
func Exists(name string) (bool, error) {
|
||||
_, err := os.Stat(name)
|
||||
if os.IsNotExist(err) {
|
||||
return false, nil
|
||||
}
|
||||
return err != nil, err
|
||||
}
|
||||
|
||||
func CreateFileOrOpenIfExist(name string) (*os.File, error) {
|
||||
exists, err := Exists(name)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if exists {
|
||||
return os.OpenFile(name, os.O_WRONLY|os.O_CREATE, 0664)
|
||||
}
|
||||
return os.Create(name)
|
||||
}
|
||||
|
||||
func CreateFileAndWriteData(filename string, lines []string) error {
|
||||
file, err := CreateFileOrOpenIfExist(filename)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
for _, line := range lines {
|
||||
_, err = fmt.Fprintf(file, line)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
err = file.Close()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func main() {
|
||||
filenames, err := GetListFilesInDirectory(INPUT)
|
||||
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
return
|
||||
}
|
||||
|
||||
var lenghtOfFilenames []string
|
||||
for _, filename := range filenames {
|
||||
fmt.Println(filename)
|
||||
lenghtOfFilenames = append(lenghtOfFilenames, fmt.Sprintf("%d", len(filename)))
|
||||
}
|
||||
|
||||
err = CreateFileAndWriteData(OUTPUT+"/data.txt", filenames)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
fmt.Println("First Service is end.")
|
||||
}
|
||||
@@ -1,30 +0,0 @@
|
||||
# Распределенные вычисления и приложения Л2
|
||||
## _Автор Базунов Андрей Игревич ПИбд-42_
|
||||
|
||||
Сервисы ( _порядок исполнения сервисов соблюден_ ):
|
||||
- 1.FileCreator - (_Создание тестовых данных_)
|
||||
- 2.FirstService - (_Выполнение 1.4 варианта задания_)
|
||||
- 3.SecondService - (_Выполнение 2.2 варианта задания_)
|
||||
|
||||
В качестве основного языка был выбран GoLang. Для каждого сервиса был создан DOCKERFILE где были прописаны условия и действия для сборки каждого из модулей
|
||||
|
||||
# Docker
|
||||
|
||||
>Перед исполнением вполняем установку docker и проверяем версию
|
||||
|
||||
```sh
|
||||
docker-compose --version
|
||||
```
|
||||
|
||||
>Далее производим настройку файла docker-compose.yaml и запускаем контейнер с сборкой образов
|
||||
|
||||
```sh
|
||||
docker-compose up -d --build
|
||||
```
|
||||
|
||||
>Для завершения работы контейнера используем команду
|
||||
```sh
|
||||
docker-compose down
|
||||
```
|
||||
|
||||
[Демонстрация работы](https://vk.com/video236673313_456239575)
|
||||
@@ -1,14 +0,0 @@
|
||||
# Используем официальный образ Go в качестве базового
|
||||
FROM golang:1.23
|
||||
|
||||
# Устанавливаем рабочую директорию
|
||||
WORKDIR /app
|
||||
|
||||
# Копируем файлы модуля
|
||||
COPY . .
|
||||
|
||||
# Сборка модуля
|
||||
RUN go build -o /bin/SecondService
|
||||
|
||||
# Запуск модуля
|
||||
CMD ["/bin/SecondService"]
|
||||
@@ -1 +0,0 @@
|
||||
module SecondService
|
||||
@@ -1,79 +0,0 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"bufio"
|
||||
"fmt"
|
||||
"os"
|
||||
)
|
||||
|
||||
//Ищет наименьшее число из файла /var/data/data.txt и сохраняет его третью степень в /var/result/result.txt.
|
||||
|
||||
const INPUT = "/var/data/data.txt"
|
||||
const OUTPUT = "/var/result/result.txt"
|
||||
|
||||
func ReadlinesFromFile(filename string) ([]string, error) {
|
||||
file, err := os.Open(filename)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
var output []string
|
||||
scanner := bufio.NewScanner(file)
|
||||
for scanner.Scan() {
|
||||
output = append(output, scanner.Text())
|
||||
}
|
||||
|
||||
err = file.Close()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return output, nil
|
||||
}
|
||||
|
||||
func WriteIntToFile(filename string, i int) error {
|
||||
file, err := os.Create(filename)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
defer func(file *os.File) {
|
||||
err := file.Close()
|
||||
if err != nil {
|
||||
|
||||
}
|
||||
}(file)
|
||||
|
||||
_, err = file.WriteString(fmt.Sprintf("%d\n", i))
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func main() {
|
||||
lines, err := ReadlinesFromFile(INPUT)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
|
||||
minValue := 0
|
||||
|
||||
for _, line := range lines {
|
||||
if intValue, err := fmt.Sscanf(line, "%d", &minValue); err != nil {
|
||||
fmt.Println(err)
|
||||
} else {
|
||||
if minValue >= intValue {
|
||||
minValue = intValue
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if err = WriteIntToFile(OUTPUT, minValue); err != nil {
|
||||
return
|
||||
} else {
|
||||
fmt.Printf("Write %d to %s\n", minValue, OUTPUT)
|
||||
}
|
||||
|
||||
fmt.Println("Second Service is end.")
|
||||
}
|
||||
@@ -1,27 +0,0 @@
|
||||
services:
|
||||
file_generate:
|
||||
build:
|
||||
context: ./FileCreator
|
||||
dockerfile: Dockerfile
|
||||
volumes:
|
||||
- ./data:/var/data # Монтирование локальной папки data в /var/data в контейнере
|
||||
|
||||
first_service:
|
||||
build:
|
||||
context: ./FirstService
|
||||
dockerfile: Dockerfile
|
||||
volumes:
|
||||
- ./data:/var/data
|
||||
- ./data:/var/result
|
||||
depends_on:
|
||||
- file_generate
|
||||
|
||||
second_service:
|
||||
build:
|
||||
context: ./SecondService
|
||||
dockerfile: Dockerfile
|
||||
volumes:
|
||||
- ./data:/var/data
|
||||
- ./data:/var/result
|
||||
depends_on:
|
||||
- first_service
|
||||
45
lazarev_andrey_lab_1/README.md
Normal file
45
lazarev_andrey_lab_1/README.md
Normal file
@@ -0,0 +1,45 @@
|
||||
# Лабораторная работа №1
|
||||
|
||||
## Описание проекта
|
||||
|
||||
Проект разворачивает 3 сервиса с использованием Docker Compose:
|
||||
1. **MySQL** - база данных;
|
||||
2. **WordPress** - платформа создания сайтов;
|
||||
3. **RabbitMQ** - брокер сообщений и веб интерфейст для работы с ним.
|
||||
|
||||
## Предварительные действия и запуск
|
||||
|
||||
1. Скачать и установить Docker и Docker Compose;
|
||||
2. Перейти в директорию с файлом docker-compose.yml;
|
||||
3. Открыть консоль и запустить сервисы командой
|
||||
```bash
|
||||
docker-compose up --build -d
|
||||
```
|
||||
4. Дождаться запуска всех сервисов
|
||||
```bash
|
||||
[+] Running 3/3
|
||||
✔ Container lazarev_andrey_lab_1-rabbitmq-1 Running 0.0s
|
||||
✔ Container lazarev_andrey_lab_1-db-1 Started 4.1s
|
||||
✔ Container lazarev_andrey_lab_1-wordpress-1 Started 3.0s
|
||||
```
|
||||
## Compose файл
|
||||
|
||||
Файл docker-compose.yml содержит комментарии к каждой строке сервисов с указанием, что они делают.
|
||||
|
||||
## Остановка сервисов
|
||||
|
||||
Для завершения работы с сервисами необходимо выполнить команду:
|
||||
```bash
|
||||
docker-compose down
|
||||
```
|
||||
Дождаться завершения работы:
|
||||
```bash
|
||||
[+] Running 4/3
|
||||
✔ Container lazarev_andrey_lab_1-wordpress-1 Removed 1.4s
|
||||
✔ Container lazarev_andrey_lab_1-rabbitmq-1 Removed 6.5s
|
||||
✔ Container lazarev_andrey_lab_1-db-1 Removed 1.3s
|
||||
```
|
||||
|
||||
## Видеодемонстрация работоспособности
|
||||
|
||||
[Демонстрация работы сервисов](https://files.ulstu.ru/s/QaG89r7ZjrFTQEk)
|
||||
44
lazarev_andrey_lab_1/docker-compose.yml
Normal file
44
lazarev_andrey_lab_1/docker-compose.yml
Normal file
@@ -0,0 +1,44 @@
|
||||
version: '3.8' # Версия Docker Compose файла
|
||||
|
||||
services: # Определение сервисов (контейнеров), которые будут запускаться
|
||||
|
||||
db: # Сервис для базы данных MySQL
|
||||
image: mysql:8.0 # Используемый образ MySQL версии 8.0
|
||||
restart: always # Автоматический перезапуск контейнера, если он завершился с ошибкой
|
||||
environment: # Переменные окружения для настройки MySQL
|
||||
MYSQL_DATABASE: bashmak # Имя создаваемой базы данных
|
||||
MYSQL_USER: admin # Имя пользователя для базы данных
|
||||
MYSQL_PASSWORD: admin # Пароль для указанного пользователя
|
||||
volumes: # Объявление томов для постоянного хранения данных MySQL
|
||||
- db:/var/lib/mysql # Привязка тома к директории данных MySQL
|
||||
|
||||
wordpress: # Сервис для запуска WordPress
|
||||
image: wordpress # Используемый образ WordPress
|
||||
restart: always # Автоматический перезапуск контейнера в случае сбоя
|
||||
depends_on: # Зависимость от сервиса базы данных (MySQL)
|
||||
- db # WordPress должен дождаться запуска MySQL
|
||||
ports: # Проброс портов
|
||||
- 8080:80 # Проброс порта 8080 на порт 80 внутри контейнера (для доступа к WordPress)
|
||||
environment: # Переменные окружения для настройки WordPress
|
||||
WORDPRESS_DB_HOST: db # Хост базы данных (название сервиса db)
|
||||
WORDPRESS_DB_USER: admin # Имя пользователя для подключения к базе данных
|
||||
WORDPRESS_DB_PASSWORD: admin # Пароль для подключения к базе данных
|
||||
WORDPRESS_DB_NAME: bashmak # Имя базы данных, к которой подключается WordPress
|
||||
volumes: # Объявление томов для постоянного хранения данных WordPress
|
||||
- wordpress:/var/www/html # Привязка тома к директории сайта WordPress
|
||||
|
||||
rabbitmq: # Сервис для RabbitMQ (брокера сообщений)
|
||||
image: rabbitmq:3.10.7-management # Используемый образ RabbitMQ с веб-интерфейсом управления
|
||||
restart: always # Автоматический перезапуск контейнера при ошибках
|
||||
ports: # Проброс портов
|
||||
- 8079:15672 # Проброс порта 8079 на порт 15672 (веб-интерфейс RabbitMQ)
|
||||
environment: # Переменные окружения для настройки RabbitMQ
|
||||
- RABBITMQ_DEFAULT_USER=simpleuser # Имя пользователя по умолчанию
|
||||
- RABBITMQ_DEFAULT_PASS=simplepass # Пароль пользователя по умолчанию
|
||||
volumes: # Объявление томов для хранения данных RabbitMQ
|
||||
- rabbitmq:/var/lib/rabbitmq # Привязка тома для постоянного хранения данных RabbitMQ
|
||||
|
||||
volumes: # Объявление именованных томов для постоянного хранения данных
|
||||
wordpress: # Том для хранения данных WordPress
|
||||
db: # Том для хранения данных MySQL
|
||||
rabbitmq: # Том для хранения данных RabbitMQ
|
||||
Reference in New Issue
Block a user