forked from v.moiseev/distributed-computing
Compare commits
2 Commits
mikhailov-
...
mikhailov-
| Author | SHA1 | Date | |
|---|---|---|---|
| e1fa178b64 | |||
| 96026e67a9 |
@@ -1,72 +0,0 @@
|
||||
# Отчет по лабораторной работе №3
|
||||
|
||||
Выполнил студент Михайлов Юрий гр. ИСЭбд-41 .
|
||||
|
||||
## REST API, Gateway и синхронный обмен между микросервисами
|
||||
|
||||
## Создание микросервисов
|
||||
|
||||
1. С помощью команды `dotnet new web -n worker-1` в терминале создали первый микросервис.
|
||||
2. Добавил решение `dotnet new sln`. Связал решение и проект командой `dotnet sln worker-1.sln add worker-1.csproj` повторил для 2-ого микросервиса.
|
||||
3. Добавил библиотеку Swagger и OpenAi в проекты и запустил с помощью команды `dotnet run`.
|
||||
|
||||
Протестированный микросервис:
|
||||
|
||||
|
||||
|
||||
## Реализация синхронного обмена.
|
||||
Реализован код, который вызывет сихронно данные из соседнего микросервиса.
|
||||
|
||||
```cs
|
||||
app.MapGet("/Сities/", async () =>
|
||||
{
|
||||
var httpClient = new HttpClient();
|
||||
var secondWorkerResponse = await httpClient.GetStringAsync("http://worker-1:8080/");
|
||||
return secondWorkerResponse.ToArray();
|
||||
})
|
||||
.WithName("GetCountries")
|
||||
.WithOpenApi();
|
||||
```
|
||||
|
||||
## Реализация gateway при помощи nginx
|
||||
|
||||
Добавил nginx.conf:
|
||||
|
||||
```conf
|
||||
server {
|
||||
listen 8080;
|
||||
listen [::]:8080;
|
||||
server_name localhost;
|
||||
location / {
|
||||
root /usr/share/nginx/html;
|
||||
index index.html index.htm;
|
||||
}
|
||||
location /worker-1/ {
|
||||
proxy_pass http://worker-1:8080/;
|
||||
proxy_set_header Host $host;
|
||||
proxy_set_header X-Real-IP $remote_addr;
|
||||
proxy_set_header X-Forwarded-Proto $scheme;
|
||||
proxy_set_header X-Forwarded-Prefix /worker-1;
|
||||
}
|
||||
location /worker-2/ {
|
||||
proxy_pass http://worker-2:8080/;
|
||||
proxy_set_header Host $host;
|
||||
proxy_set_header X-Real-IP $remote_addr;
|
||||
proxy_set_header X-Forwarded-Proto $scheme;
|
||||
proxy_set_header X-Forwarded-Prefix /worker-2;
|
||||
}
|
||||
}
|
||||
```
|
||||
Результат после команды `docker-compose up`:
|
||||
|
||||
Docker desktop:
|
||||
|
||||
|
||||
index.html на gateway-1:
|
||||
|
||||
|
||||
worker-1:
|
||||
|
||||
|
||||
worker-2:
|
||||
|
||||
@@ -1,15 +0,0 @@
|
||||
version: "3.1"
|
||||
services:
|
||||
worker-1:
|
||||
build: ./worker-1
|
||||
worker-2:
|
||||
build: ./worker-2
|
||||
depends_on:
|
||||
- worker-1
|
||||
gateway:
|
||||
image: nginx:latest
|
||||
ports:
|
||||
- 8080:8080
|
||||
volumes:
|
||||
- ./static:/usr/share/nginx/html:ro
|
||||
- ./nginx.conf:/etc/nginx/conf.d/default.conf:ro
|
||||
@@ -1,26 +0,0 @@
|
||||
server {
|
||||
listen 8080;
|
||||
listen [::]:8080;
|
||||
server_name localhost;
|
||||
|
||||
location / {
|
||||
root /usr/share/nginx/html;
|
||||
index index.html index.htm;
|
||||
}
|
||||
|
||||
location /worker-1/ {
|
||||
proxy_pass http://worker-1:8080/;
|
||||
proxy_set_header Host $host;
|
||||
proxy_set_header X-Real-IP $remote_addr;
|
||||
proxy_set_header X-Forwarded-Proto $scheme;
|
||||
proxy_set_header X-Forwarded-Prefix /worker-1;
|
||||
}
|
||||
|
||||
location /worker-2/ {
|
||||
proxy_pass http://worker-2:8080/;
|
||||
proxy_set_header Host $host;
|
||||
proxy_set_header X-Real-IP $remote_addr;
|
||||
proxy_set_header X-Forwarded-Proto $scheme;
|
||||
proxy_set_header X-Forwarded-Prefix /worker-2;
|
||||
}
|
||||
}
|
||||
Binary file not shown.
|
Before Width: | Height: | Size: 120 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 103 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 82 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 48 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 66 KiB |
@@ -1,13 +0,0 @@
|
||||
<!DOCTYPE html>
|
||||
<html lang="ru">
|
||||
<head>
|
||||
<meta charset="UTF-8">
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||
<title>Тестовое приложение для л/р 3</title>
|
||||
</head>
|
||||
<body>
|
||||
<p>Выполнил студент гр. ИСЭбд-41. Михайлов Юрий</p>
|
||||
<p><a href="/worker-1/">Отправить запрос к worker-1</a></p>
|
||||
<p><a href="/worker-2/">Отправить запрос к worker-2</a></p>
|
||||
</body>
|
||||
</html>
|
||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
File diff suppressed because it is too large
Load Diff
Binary file not shown.
Binary file not shown.
@@ -1,11 +0,0 @@
|
||||
FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build-env
|
||||
WORKDIR /app
|
||||
|
||||
COPY . ./
|
||||
RUN dotnet restore
|
||||
RUN dotnet publish -c Release -o out
|
||||
|
||||
FROM mcr.microsoft.com/dotnet/aspnet:8.0
|
||||
WORKDIR /app
|
||||
COPY --from=build-env /app/out .
|
||||
ENTRYPOINT ["dotnet", "worker-1.dll"]
|
||||
@@ -1,118 +0,0 @@
|
||||
List<Countries > countries = new()
|
||||
{
|
||||
new Countries () { Uuid= Guid.Parse("6a1b4a72-5669-41fe-8d5b-106dc86f58bd"), Name = "Russia", Area = "1222" },
|
||||
new Countries () { Uuid= Guid.Parse("464bbdb8-39c0-4644-b9c0-3df1c484ea7e"), Name = "USA", Area = "0" },
|
||||
new Countries () { Uuid= Guid.Parse("f8692bea-b7e6-4164-b564-a921f16c35c9"), Name = "Germany", Area = "1" },
|
||||
|
||||
};
|
||||
|
||||
var builder = WebApplication.CreateBuilder(args);
|
||||
|
||||
builder.Services.AddEndpointsApiExplorer();
|
||||
builder.Services.AddSwaggerGen();
|
||||
|
||||
var app = builder.Build();
|
||||
|
||||
if (app.Environment.IsDevelopment())
|
||||
{
|
||||
app.UseSwagger();
|
||||
app.UseSwaggerUI();
|
||||
}
|
||||
|
||||
app.UseHttpsRedirection();
|
||||
|
||||
app.MapGet("/", () =>
|
||||
{
|
||||
return countries.Select(r => new CountrieEntityDto()
|
||||
{
|
||||
Uuid = r.Uuid,
|
||||
Name = r.Name,
|
||||
Area = r.Area,
|
||||
|
||||
});
|
||||
})
|
||||
.WithName("GetCountries")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapGet("/{uuid}", (Guid uuid) =>
|
||||
{
|
||||
var countrie = countries.FirstOrDefault(r => r.Uuid == uuid);
|
||||
if (countrie == null)
|
||||
return Results.NotFound();
|
||||
return Results.Json(new CountrieEntityDto()
|
||||
{
|
||||
Uuid = countrie.Uuid,
|
||||
Name = countrie.Name,
|
||||
Area = countrie.Area,
|
||||
|
||||
});
|
||||
})
|
||||
.WithName("GetCountrieByGUID")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapPost("/{name}/{area}", (string name, string area) =>
|
||||
{
|
||||
Guid NewGuid = Guid.NewGuid();
|
||||
countries.Add(new Countries() { Uuid = NewGuid, Name = (string)name, Area = (string)area});
|
||||
|
||||
var countrie = countries.FirstOrDefault(r => r.Uuid == NewGuid);
|
||||
if (countrie == null)
|
||||
return Results.NotFound();
|
||||
return Results.Json(new CountrieEntityDto()
|
||||
{
|
||||
Uuid = countrie.Uuid,
|
||||
Name = countrie.Name,
|
||||
Area = countrie.Area,
|
||||
|
||||
});
|
||||
})
|
||||
.WithName("PostCountrie")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapPatch("/{uuid}/{name}/{area}", (Guid uuid, string ?name, string ?area) =>
|
||||
{
|
||||
var countrie = countries.FirstOrDefault(r => r.Uuid == uuid);
|
||||
if (countrie == null)
|
||||
return Results.NotFound();
|
||||
if (name != null) countrie.Name = name;
|
||||
if (area != ",") countrie.Area = area;
|
||||
|
||||
|
||||
return Results.Json(new CountrieEntityDto()
|
||||
{
|
||||
Uuid = countrie.Uuid,
|
||||
Name = countrie.Name,
|
||||
Area = countrie.Area,
|
||||
|
||||
});
|
||||
})
|
||||
.WithName("UpdateCountrie")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapDelete("/{uuid}", (Guid uuid) =>
|
||||
{
|
||||
var countrie = countries.FirstOrDefault(r => r.Uuid == uuid);
|
||||
if (countrie == null)
|
||||
return Results.NotFound();
|
||||
countries.Remove(countrie);
|
||||
return Results.Json(new CountrieEntityDto()
|
||||
{
|
||||
Uuid = countrie.Uuid,
|
||||
Name = countrie.Name,
|
||||
Area = countrie.Area,
|
||||
|
||||
});
|
||||
})
|
||||
.WithName("DeleteCountrieByGUID")
|
||||
.WithOpenApi();
|
||||
|
||||
app.Run();
|
||||
|
||||
public class Countries
|
||||
{
|
||||
public Guid Uuid { get; set; }
|
||||
public string Name { get; set; } = string.Empty;
|
||||
public string Area { get; set; } = string.Empty;
|
||||
}
|
||||
|
||||
public class CountrieEntityDto : Countries { }
|
||||
@@ -1,38 +0,0 @@
|
||||
{
|
||||
"$schema": "http://json.schemastore.org/launchsettings.json",
|
||||
"iisSettings": {
|
||||
"windowsAuthentication": false,
|
||||
"anonymousAuthentication": true,
|
||||
"iisExpress": {
|
||||
"applicationUrl": "http://localhost:51956",
|
||||
"sslPort": 44303
|
||||
}
|
||||
},
|
||||
"profiles": {
|
||||
"http": {
|
||||
"commandName": "Project",
|
||||
"dotnetRunMessages": true,
|
||||
"launchBrowser": true,
|
||||
"applicationUrl": "http://localhost:5197",
|
||||
"environmentVariables": {
|
||||
"ASPNETCORE_ENVIRONMENT": "Development"
|
||||
}
|
||||
},
|
||||
"https": {
|
||||
"commandName": "Project",
|
||||
"dotnetRunMessages": true,
|
||||
"launchBrowser": true,
|
||||
"applicationUrl": "https://localhost:7027;http://localhost:5197",
|
||||
"environmentVariables": {
|
||||
"ASPNETCORE_ENVIRONMENT": "Development"
|
||||
}
|
||||
},
|
||||
"IIS Express": {
|
||||
"commandName": "IISExpress",
|
||||
"launchBrowser": true,
|
||||
"environmentVariables": {
|
||||
"ASPNETCORE_ENVIRONMENT": "Development"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,8 +0,0 @@
|
||||
{
|
||||
"Logging": {
|
||||
"LogLevel": {
|
||||
"Default": "Information",
|
||||
"Microsoft.AspNetCore": "Warning"
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,9 +0,0 @@
|
||||
{
|
||||
"Logging": {
|
||||
"LogLevel": {
|
||||
"Default": "Information",
|
||||
"Microsoft.AspNetCore": "Warning"
|
||||
}
|
||||
},
|
||||
"AllowedHosts": "*"
|
||||
}
|
||||
@@ -1,15 +0,0 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk.Web">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net8.0</TargetFramework>
|
||||
<Nullable>enable</Nullable>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<RootNamespace>worker_1</RootNamespace>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="8.0.0" />
|
||||
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
@@ -1,6 +0,0 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
|
||||
<PropertyGroup>
|
||||
<ActiveDebugProfile>https</ActiveDebugProfile>
|
||||
</PropertyGroup>
|
||||
</Project>
|
||||
@@ -1,22 +0,0 @@
|
||||
|
||||
Microsoft Visual Studio Solution File, Format Version 12.00
|
||||
# Visual Studio Version 17
|
||||
VisualStudioVersion = 17.0.31903.59
|
||||
MinimumVisualStudioVersion = 10.0.40219.1
|
||||
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "worker-1", "worker-1.csproj", "{90F6C7BD-78E2-47C8-A702-DD47E74D3865}"
|
||||
EndProject
|
||||
Global
|
||||
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||
Debug|Any CPU = Debug|Any CPU
|
||||
Release|Any CPU = Release|Any CPU
|
||||
EndGlobalSection
|
||||
GlobalSection(SolutionProperties) = preSolution
|
||||
HideSolutionNode = FALSE
|
||||
EndGlobalSection
|
||||
GlobalSection(ProjectConfigurationPlatforms) = postSolution
|
||||
{90F6C7BD-78E2-47C8-A702-DD47E74D3865}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{90F6C7BD-78E2-47C8-A702-DD47E74D3865}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{90F6C7BD-78E2-47C8-A702-DD47E74D3865}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{90F6C7BD-78E2-47C8-A702-DD47E74D3865}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
EndGlobalSection
|
||||
EndGlobal
|
||||
Binary file not shown.
File diff suppressed because it is too large
Load Diff
Binary file not shown.
@@ -1,11 +0,0 @@
|
||||
FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build-env
|
||||
WORKDIR /app
|
||||
|
||||
COPY . ./
|
||||
RUN dotnet restore
|
||||
RUN dotnet publish -c Release -o out
|
||||
|
||||
FROM mcr.microsoft.com/dotnet/aspnet:8.0
|
||||
WORKDIR /app
|
||||
COPY --from=build-env /app/out .
|
||||
ENTRYPOINT ["dotnet", "worker-2.dll"]
|
||||
@@ -1,142 +0,0 @@
|
||||
using Microsoft.Extensions.DependencyInjection;
|
||||
using Microsoft.AspNetCore.Builder;
|
||||
using Microsoft.OpenApi.Models;
|
||||
|
||||
List<Сities> сities = new()
|
||||
{
|
||||
new Сities() { Uuid= Guid.NewGuid(), Population = "134r23", Name = "Moscow", IdCountrie = Guid.Parse("6a1b4a72-5669-41fe-8d5b-106dc86f58bd") },
|
||||
new Сities() { Uuid= Guid.NewGuid(), Population = "223322213", Name = "Paris", IdCountrie = Guid.Parse("f8692bea-b7e6-4164-b564-a921f16c35c9") },
|
||||
new Сities() { Uuid= Guid.NewGuid(), Population = "32123", Name = "New York", IdCountrie = Guid.Parse("464bbdb8-39c0-4644-b9c0-3df1c484ea7e") },
|
||||
new Сities() { Uuid= Guid.NewGuid(), Population = "312122", Name = "Sant Peterburg", IdCountrie = Guid.Parse("464bbdb8-39c0-4644-b9c0-3df1c484ea7e") },
|
||||
};
|
||||
|
||||
var builder = WebApplication.CreateBuilder(args);
|
||||
|
||||
builder.Services.AddEndpointsApiExplorer();
|
||||
builder.Services.AddSwaggerGen();
|
||||
|
||||
var app = builder.Build();
|
||||
|
||||
if (app.Environment.IsDevelopment())
|
||||
{
|
||||
app.UseSwagger();
|
||||
app.UseSwaggerUI();
|
||||
}
|
||||
|
||||
app.UseHttpsRedirection();
|
||||
|
||||
app.MapGet("/", () =>
|
||||
{
|
||||
return сities.Select(r => new CityEntityDto()
|
||||
{
|
||||
Uuid = r.Uuid,
|
||||
Population = r.Population,
|
||||
Name = r.Name,
|
||||
IdCountrie = r.IdCountrie,
|
||||
});
|
||||
})
|
||||
.WithName("GetСities")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapGet("/{uuid}", (Guid uuid) =>
|
||||
{
|
||||
var city = сities.FirstOrDefault(r => r.Uuid == uuid);
|
||||
if (city == null)
|
||||
return Results.NotFound();
|
||||
return Results.Json(new CityEntityDto()
|
||||
{
|
||||
Uuid = city.Uuid,
|
||||
Population = city.Population,
|
||||
Name = city.Name,
|
||||
IdCountrie = city.IdCountrie,
|
||||
});
|
||||
})
|
||||
.WithName("GetCityByGUID")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapPost("/{population}/{name}/{IdCountrie}", (string? Population, string Name, Guid IdCountrie) =>
|
||||
{
|
||||
Guid NewGuid = Guid.NewGuid();
|
||||
сities.Add(new Сities() { Uuid = NewGuid, Population = (string)Population, Name = (string)Name, IdCountrie = (Guid)IdCountrie });
|
||||
|
||||
var city = сities.FirstOrDefault(r => r.Uuid == NewGuid);
|
||||
if (city == null)
|
||||
return Results.NotFound();
|
||||
return Results.Json(new CityEntityDto()
|
||||
{
|
||||
Uuid = city.Uuid,
|
||||
Population = city.Population,
|
||||
Name = city.Name,
|
||||
IdCountrie = city.IdCountrie,
|
||||
});
|
||||
})
|
||||
.WithName("PostCity")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapPatch("/{uuid}/{population}/{name}/{IdCountrie}", (Guid uuid, string ?population, string name, Guid IdCountrie) =>
|
||||
{
|
||||
var city = сities.FirstOrDefault(r => r.Uuid == uuid);
|
||||
if (city == null)
|
||||
return Results.NotFound();
|
||||
if (population != ",") city.Population = population;
|
||||
if (name != city.Name) city.Name = name;
|
||||
if (IdCountrie != city.IdCountrie) city.IdCountrie = IdCountrie;
|
||||
|
||||
return Results.Json(new CityEntityDto()
|
||||
{
|
||||
Uuid = city.Uuid,
|
||||
Population = city.Population,
|
||||
Name = city.Name,
|
||||
IdCountrie = city.IdCountrie,
|
||||
});
|
||||
})
|
||||
.WithName("UpdateCity")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapDelete("/{uuid}", (Guid uuid) =>
|
||||
{
|
||||
var city = сities.FirstOrDefault(r => r.Uuid == uuid);
|
||||
if (city == null)
|
||||
return Results.NotFound();
|
||||
сities.Remove(city);
|
||||
return Results.Json(new CityEntityDto()
|
||||
{
|
||||
Uuid = city.Uuid,
|
||||
Population = city.Population,
|
||||
Name = city.Name,
|
||||
IdCountrie = city.IdCountrie,
|
||||
});
|
||||
})
|
||||
.WithName("DeleteCity")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapGet("/Сities/", async () =>
|
||||
{
|
||||
var httpClient = new HttpClient();
|
||||
var secondWorkerResponse = await httpClient.GetStringAsync("http://worker-1:8080/");
|
||||
|
||||
return secondWorkerResponse.ToArray();
|
||||
})
|
||||
.WithName("GetCountries")
|
||||
.WithOpenApi();
|
||||
|
||||
app.Run();
|
||||
|
||||
public class Сities
|
||||
{
|
||||
public Guid Uuid { get; set; }
|
||||
public string Population { get; set; } = string.Empty;
|
||||
public string Name { get; set; } = string.Empty;
|
||||
public Guid IdCountrie { get; set; }
|
||||
}
|
||||
|
||||
public class CityEntityDto : Сities { }
|
||||
|
||||
public class Countries
|
||||
{
|
||||
public Guid Uuid { get; set; }
|
||||
public string Name { get; set; } = string.Empty;
|
||||
public string Area { get; set; } = string.Empty;
|
||||
}
|
||||
|
||||
public class CountrieEntityDto : Countries { }
|
||||
@@ -1,38 +0,0 @@
|
||||
{
|
||||
"$schema": "http://json.schemastore.org/launchsettings.json",
|
||||
"iisSettings": {
|
||||
"windowsAuthentication": false,
|
||||
"anonymousAuthentication": true,
|
||||
"iisExpress": {
|
||||
"applicationUrl": "http://localhost:36404",
|
||||
"sslPort": 44384
|
||||
}
|
||||
},
|
||||
"profiles": {
|
||||
"http": {
|
||||
"commandName": "Project",
|
||||
"dotnetRunMessages": true,
|
||||
"launchBrowser": true,
|
||||
"applicationUrl": "http://localhost:5101",
|
||||
"environmentVariables": {
|
||||
"ASPNETCORE_ENVIRONMENT": "Development"
|
||||
}
|
||||
},
|
||||
"https": {
|
||||
"commandName": "Project",
|
||||
"dotnetRunMessages": true,
|
||||
"launchBrowser": true,
|
||||
"applicationUrl": "https://localhost:7125;http://localhost:5101",
|
||||
"environmentVariables": {
|
||||
"ASPNETCORE_ENVIRONMENT": "Development"
|
||||
}
|
||||
},
|
||||
"IIS Express": {
|
||||
"commandName": "IISExpress",
|
||||
"launchBrowser": true,
|
||||
"environmentVariables": {
|
||||
"ASPNETCORE_ENVIRONMENT": "Development"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,8 +0,0 @@
|
||||
{
|
||||
"Logging": {
|
||||
"LogLevel": {
|
||||
"Default": "Information",
|
||||
"Microsoft.AspNetCore": "Warning"
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,9 +0,0 @@
|
||||
{
|
||||
"Logging": {
|
||||
"LogLevel": {
|
||||
"Default": "Information",
|
||||
"Microsoft.AspNetCore": "Warning"
|
||||
}
|
||||
},
|
||||
"AllowedHosts": "*"
|
||||
}
|
||||
@@ -1,15 +0,0 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk.Web">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net8.0</TargetFramework>
|
||||
<Nullable>enable</Nullable>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<RootNamespace>worker_2</RootNamespace>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="8.0.0" />
|
||||
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
@@ -1,6 +0,0 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
|
||||
<PropertyGroup>
|
||||
<ActiveDebugProfile>https</ActiveDebugProfile>
|
||||
</PropertyGroup>
|
||||
</Project>
|
||||
@@ -1,22 +0,0 @@
|
||||
|
||||
Microsoft Visual Studio Solution File, Format Version 12.00
|
||||
# Visual Studio Version 17
|
||||
VisualStudioVersion = 17.0.31903.59
|
||||
MinimumVisualStudioVersion = 10.0.40219.1
|
||||
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "worker-2", "worker-2.csproj", "{C9D63524-2C63-4E86-91B6-D86955CFA5F8}"
|
||||
EndProject
|
||||
Global
|
||||
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||
Debug|Any CPU = Debug|Any CPU
|
||||
Release|Any CPU = Release|Any CPU
|
||||
EndGlobalSection
|
||||
GlobalSection(SolutionProperties) = preSolution
|
||||
HideSolutionNode = FALSE
|
||||
EndGlobalSection
|
||||
GlobalSection(ProjectConfigurationPlatforms) = postSolution
|
||||
{C9D63524-2C63-4E86-91B6-D86955CFA5F8}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{C9D63524-2C63-4E86-91B6-D86955CFA5F8}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{C9D63524-2C63-4E86-91B6-D86955CFA5F8}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{C9D63524-2C63-4E86-91B6-D86955CFA5F8}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
EndGlobalSection
|
||||
EndGlobal
|
||||
@@ -1,3 +1,5 @@
|
||||
var/result/
|
||||
|
||||
## Ignore Visual Studio temporary files, build results, and
|
||||
## files generated by popular Visual Studio add-ons.
|
||||
##
|
||||
15
tasks/mikhailov-ys/lab_4/Main/Consumer1/Consumer1.csproj
Normal file
15
tasks/mikhailov-ys/lab_4/Main/Consumer1/Consumer1.csproj
Normal file
@@ -0,0 +1,15 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ" Version="3.6.2" />
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
31
tasks/mikhailov-ys/lab_4/Main/Consumer1/Program.cs
Normal file
31
tasks/mikhailov-ys/lab_4/Main/Consumer1/Program.cs
Normal file
@@ -0,0 +1,31 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.QueueDeclare(queue: "accepted");
|
||||
channel.QueueBind(queue: "accepted",
|
||||
exchange: "report",
|
||||
routingKey: string.Empty);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for messages.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += async (model, ea) =>
|
||||
{
|
||||
byte[] body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
|
||||
string outputText = $"Заявление принято к обработке {message}";
|
||||
Console.WriteLine($" [x] Done. {outputText}");
|
||||
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
|
||||
};
|
||||
channel.BasicConsume(queue: "accepted",
|
||||
autoAck: false,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
15
tasks/mikhailov-ys/lab_4/Main/Consumer2/Consumer2.csproj
Normal file
15
tasks/mikhailov-ys/lab_4/Main/Consumer2/Consumer2.csproj
Normal file
@@ -0,0 +1,15 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ" Version="3.6.2" />
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
37
tasks/mikhailov-ys/lab_4/Main/Consumer2/Program.cs
Normal file
37
tasks/mikhailov-ys/lab_4/Main/Consumer2/Program.cs
Normal file
@@ -0,0 +1,37 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
Random rand = new Random();
|
||||
string queueName = $"denied{rand.Next()}";
|
||||
|
||||
channel.QueueDeclare(queue: queueName);
|
||||
channel.QueueBind(queue: queueName,
|
||||
exchange: "report",
|
||||
routingKey: string.Empty);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for messages.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += async (model, ea) =>
|
||||
{
|
||||
byte[] body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
|
||||
int waitTime = rand.Next(20, 90);
|
||||
Thread.Sleep(waitTime * 100);
|
||||
|
||||
string outputText = $"Заявление обработано {message} за {waitTime} минут";
|
||||
Console.WriteLine($" [x] Done. {outputText}");
|
||||
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
|
||||
};
|
||||
channel.BasicConsume(queue: queueName,
|
||||
autoAck: false,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
30
tasks/mikhailov-ys/lab_4/Main/Publisher/Program.cs
Normal file
30
tasks/mikhailov-ys/lab_4/Main/Publisher/Program.cs
Normal file
@@ -0,0 +1,30 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.ExchangeDeclare(exchange: "report", type: ExchangeType.Fanout);
|
||||
Random rand = new Random();
|
||||
foreach (var item in Enumerable.Range(0, 1000))
|
||||
{
|
||||
var message = rand.Next().ToString();
|
||||
|
||||
var body = Encoding.UTF8.GetBytes(message);
|
||||
channel.BasicPublish(exchange: "report",
|
||||
routingKey: string.Empty,
|
||||
basicProperties: null,
|
||||
body: body);
|
||||
|
||||
Console.WriteLine($" [x] Поступило заявление {message}");
|
||||
await Task.Delay(500);
|
||||
}
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
|
||||
static string GetMessage(string[] args)
|
||||
{
|
||||
return ((args.Length > 0) ? string.Join(" ", args) : "info: Принято!");
|
||||
}
|
||||
15
tasks/mikhailov-ys/lab_4/Main/Publisher/Publisher.csproj
Normal file
15
tasks/mikhailov-ys/lab_4/Main/Publisher/Publisher.csproj
Normal file
@@ -0,0 +1,15 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ" Version="3.6.2" />
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
149
tasks/mikhailov-ys/lab_4/README.md
Normal file
149
tasks/mikhailov-ys/lab_4/README.md
Normal file
@@ -0,0 +1,149 @@
|
||||
# Отчёт по лабораторной работе №4
|
||||
|
||||
Выполнил: студент гр. ИСЭбд-41 Михайлов Ю.С.
|
||||
|
||||
## Прохождение туториалов
|
||||
|
||||
Установил RabbitMQ, Erlang и зашел в брокер под гостем по адресу http://localhost:15672/#/
|
||||
|
||||
Туториал 1:
|
||||
|
||||
|
||||
|
||||
|
||||
Туториал 2:
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
Туториал 3:
|
||||
|
||||
|
||||
|
||||
|
||||
## Разработка демонстрационных приложений
|
||||
|
||||
Предметная область - оформление заявлений на стипендию в университете. Разработано три приложения согласно предметной области.
|
||||
|
||||
1. Publisher:
|
||||
```
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.ExchangeDeclare(exchange: "report", type: ExchangeType.Fanout);
|
||||
Random rand = new Random();
|
||||
foreach (var item in Enumerable.Range(0, 1000))
|
||||
{
|
||||
var message = rand.Next().ToString();
|
||||
|
||||
var body = Encoding.UTF8.GetBytes(message);
|
||||
channel.BasicPublish(exchange: "report",
|
||||
routingKey: string.Empty,
|
||||
basicProperties: null,
|
||||
body: body);
|
||||
|
||||
Console.WriteLine($" [x] Поступило заявление {message}");
|
||||
await Task.Delay(500);
|
||||
}
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
|
||||
static string GetMessage(string[] args)
|
||||
{
|
||||
return ((args.Length > 0) ? string.Join(" ", args) : "info: Принято!");
|
||||
}
|
||||
```
|
||||
2. Consumer 1:
|
||||
```
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.QueueDeclare(queue: "accepted");
|
||||
channel.QueueBind(queue: "accepted",
|
||||
exchange: "report",
|
||||
routingKey: string.Empty);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for messages.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += async (model, ea) =>
|
||||
{
|
||||
byte[] body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
|
||||
string outputText = $"Заявление принято к обработке {message}";
|
||||
Console.WriteLine($" [x] Done. {outputText}");
|
||||
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
|
||||
};
|
||||
channel.BasicConsume(queue: "accepted",
|
||||
autoAck: false,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
```
|
||||
|
||||
3. Consumer 3:
|
||||
```
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
Random rand = new Random();
|
||||
string queueName = $"denied{rand.Next()}";
|
||||
|
||||
channel.QueueDeclare(queue: queueName);
|
||||
channel.QueueBind(queue: queueName,
|
||||
exchange: "report",
|
||||
routingKey: string.Empty);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for messages.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += async (model, ea) =>
|
||||
{
|
||||
byte[] body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
|
||||
int waitTime = rand.Next(20, 90);
|
||||
Thread.Sleep(waitTime * 100);
|
||||
|
||||
string outputText = $"Заявление обработано {message} за {waitTime} минут";
|
||||
Console.WriteLine($" [x] Done. {outputText}");
|
||||
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
|
||||
};
|
||||
channel.BasicConsume(queue: queueName,
|
||||
autoAck: false,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
```
|
||||
|
||||
## Результаты выполнения работы
|
||||
|
||||
Запуск каждой программы:
|
||||
|
||||
|
||||
|
||||
|
||||
Результаты обработки:
|
||||
|
||||
|
||||
|
||||
Вывод: Consumer_2 нагружает меньше памяти, чем Consumer_1 и принимает сообщения гораздо быстрее, тем самым не позволяя очереди накапливать огромное количество сообщений
|
||||
92
tasks/mikhailov-ys/lab_4/lab_4.sln
Normal file
92
tasks/mikhailov-ys/lab_4/lab_4.sln
Normal file
@@ -0,0 +1,92 @@
|
||||
|
||||
Microsoft Visual Studio Solution File, Format Version 12.00
|
||||
# Visual Studio Version 17
|
||||
VisualStudioVersion = 17.5.002.0
|
||||
MinimumVisualStudioVersion = 10.0.40219.1
|
||||
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Main", "Main", "{964E2358-8624-4435-A0C6-5B4E3C44DB7A}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Consumer1", "Main\Consumer1\Consumer1.csproj", "{62525D49-B416-41D2-92DC-3025ABD8FED2}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Consumer2", "Main\Consumer2\Consumer2.csproj", "{71B9FCAD-EDBC-42C7-951E-2CEACB18B0AD}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Publisher", "Main\Publisher\Publisher.csproj", "{DAE03D67-36C7-424E-87F3-3D900293BA39}"
|
||||
EndProject
|
||||
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "tut1", "tut1", "{E28D0800-55F2-44CC-AF62-9524F6E70A1B}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Receive", "tut1\Receive\Receive.csproj", "{A8885758-2115-43E0-8672-5B0E2B33FB57}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Send", "tut1\Send\Send.csproj", "{D2ABDEBD-9E8D-4F38-A5BF-7F469EDB9B8C}"
|
||||
EndProject
|
||||
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "tut2", "tut2", "{0E1855BF-5771-45F9-BB46-5D075DE99313}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "NewTask", "tut2\NewTask\NewTask.csproj", "{F06A67F1-1606-4D01-84C6-10CE4F4A5273}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Worker", "tut2\Worker\Worker.csproj", "{22F91487-772C-4DA4-9BAC-D6BB44B10D6C}"
|
||||
EndProject
|
||||
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "tut3", "tut3", "{D12C599A-23A2-4139-96A3-8188BC6135E2}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "EmitLogs", "tut3\EmitLogs\EmitLogs.csproj", "{61B1A285-7B3C-4B60-8001-0757E6A88EA9}"
|
||||
EndProject
|
||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ReceiveLogs", "tut3\ReceiveLogs\ReceiveLogs.csproj", "{63AE28E6-F4E0-40E1-AAAC-F1C11111CFE8}"
|
||||
EndProject
|
||||
Global
|
||||
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||
Debug|Any CPU = Debug|Any CPU
|
||||
Release|Any CPU = Release|Any CPU
|
||||
EndGlobalSection
|
||||
GlobalSection(ProjectConfigurationPlatforms) = postSolution
|
||||
{62525D49-B416-41D2-92DC-3025ABD8FED2}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{62525D49-B416-41D2-92DC-3025ABD8FED2}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{62525D49-B416-41D2-92DC-3025ABD8FED2}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{62525D49-B416-41D2-92DC-3025ABD8FED2}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{71B9FCAD-EDBC-42C7-951E-2CEACB18B0AD}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{71B9FCAD-EDBC-42C7-951E-2CEACB18B0AD}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{71B9FCAD-EDBC-42C7-951E-2CEACB18B0AD}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{71B9FCAD-EDBC-42C7-951E-2CEACB18B0AD}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{DAE03D67-36C7-424E-87F3-3D900293BA39}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{DAE03D67-36C7-424E-87F3-3D900293BA39}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{DAE03D67-36C7-424E-87F3-3D900293BA39}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{DAE03D67-36C7-424E-87F3-3D900293BA39}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{A8885758-2115-43E0-8672-5B0E2B33FB57}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{A8885758-2115-43E0-8672-5B0E2B33FB57}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{A8885758-2115-43E0-8672-5B0E2B33FB57}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{A8885758-2115-43E0-8672-5B0E2B33FB57}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{D2ABDEBD-9E8D-4F38-A5BF-7F469EDB9B8C}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{D2ABDEBD-9E8D-4F38-A5BF-7F469EDB9B8C}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{D2ABDEBD-9E8D-4F38-A5BF-7F469EDB9B8C}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{D2ABDEBD-9E8D-4F38-A5BF-7F469EDB9B8C}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{F06A67F1-1606-4D01-84C6-10CE4F4A5273}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{F06A67F1-1606-4D01-84C6-10CE4F4A5273}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{F06A67F1-1606-4D01-84C6-10CE4F4A5273}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{F06A67F1-1606-4D01-84C6-10CE4F4A5273}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{22F91487-772C-4DA4-9BAC-D6BB44B10D6C}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{22F91487-772C-4DA4-9BAC-D6BB44B10D6C}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{22F91487-772C-4DA4-9BAC-D6BB44B10D6C}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{22F91487-772C-4DA4-9BAC-D6BB44B10D6C}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{61B1A285-7B3C-4B60-8001-0757E6A88EA9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{61B1A285-7B3C-4B60-8001-0757E6A88EA9}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{61B1A285-7B3C-4B60-8001-0757E6A88EA9}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{61B1A285-7B3C-4B60-8001-0757E6A88EA9}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{63AE28E6-F4E0-40E1-AAAC-F1C11111CFE8}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{63AE28E6-F4E0-40E1-AAAC-F1C11111CFE8}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{63AE28E6-F4E0-40E1-AAAC-F1C11111CFE8}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{63AE28E6-F4E0-40E1-AAAC-F1C11111CFE8}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
EndGlobalSection
|
||||
GlobalSection(SolutionProperties) = preSolution
|
||||
HideSolutionNode = FALSE
|
||||
EndGlobalSection
|
||||
GlobalSection(NestedProjects) = preSolution
|
||||
{62525D49-B416-41D2-92DC-3025ABD8FED2} = {964E2358-8624-4435-A0C6-5B4E3C44DB7A}
|
||||
{71B9FCAD-EDBC-42C7-951E-2CEACB18B0AD} = {964E2358-8624-4435-A0C6-5B4E3C44DB7A}
|
||||
{DAE03D67-36C7-424E-87F3-3D900293BA39} = {964E2358-8624-4435-A0C6-5B4E3C44DB7A}
|
||||
{A8885758-2115-43E0-8672-5B0E2B33FB57} = {E28D0800-55F2-44CC-AF62-9524F6E70A1B}
|
||||
{D2ABDEBD-9E8D-4F38-A5BF-7F469EDB9B8C} = {E28D0800-55F2-44CC-AF62-9524F6E70A1B}
|
||||
{F06A67F1-1606-4D01-84C6-10CE4F4A5273} = {0E1855BF-5771-45F9-BB46-5D075DE99313}
|
||||
{22F91487-772C-4DA4-9BAC-D6BB44B10D6C} = {0E1855BF-5771-45F9-BB46-5D075DE99313}
|
||||
{61B1A285-7B3C-4B60-8001-0757E6A88EA9} = {D12C599A-23A2-4139-96A3-8188BC6135E2}
|
||||
{63AE28E6-F4E0-40E1-AAAC-F1C11111CFE8} = {D12C599A-23A2-4139-96A3-8188BC6135E2}
|
||||
EndGlobalSection
|
||||
GlobalSection(ExtensibilityGlobals) = postSolution
|
||||
SolutionGuid = {A916E577-C16A-4BBF-A3BE-9491C0F5B147}
|
||||
EndGlobalSection
|
||||
EndGlobal
|
||||
BIN
tasks/mikhailov-ys/lab_4/pic/1.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/1.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 17 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/10.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/10.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 71 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/11.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/11.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 56 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/12.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/12.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 63 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/13.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/13.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 37 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/14.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/14.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 61 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/15.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/15.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 77 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/2.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/2.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 16 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/3.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/3.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 78 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/4.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/4.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 24 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/5.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/5.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 21 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/6.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/6.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 40 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/7.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/7.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 82 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/8.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/8.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 6.2 KiB |
BIN
tasks/mikhailov-ys/lab_4/pic/9.PNG
Normal file
BIN
tasks/mikhailov-ys/lab_4/pic/9.PNG
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 7.7 KiB |
29
tasks/mikhailov-ys/lab_4/tut1/Receive/Receive.cs
Normal file
29
tasks/mikhailov-ys/lab_4/tut1/Receive/Receive.cs
Normal file
@@ -0,0 +1,29 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.QueueDeclare(queue: "hello",
|
||||
durable: false,
|
||||
exclusive: false,
|
||||
autoDelete: false,
|
||||
arguments: null);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for messages.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += (model, ea) =>
|
||||
{
|
||||
var body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
Console.WriteLine($" [x] Received {message}");
|
||||
};
|
||||
channel.BasicConsume(queue: "hello",
|
||||
autoAck: true,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
14
tasks/mikhailov-ys/lab_4/tut1/Receive/Receive.csproj
Normal file
14
tasks/mikhailov-ys/lab_4/tut1/Receive/Receive.csproj
Normal file
@@ -0,0 +1,14 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
24
tasks/mikhailov-ys/lab_4/tut1/Send/Send.cs
Normal file
24
tasks/mikhailov-ys/lab_4/tut1/Send/Send.cs
Normal file
@@ -0,0 +1,24 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.QueueDeclare(queue: "hello",
|
||||
durable: false,
|
||||
exclusive: false,
|
||||
autoDelete: false,
|
||||
arguments: null);
|
||||
|
||||
const string message = "Hello World!";
|
||||
var body = Encoding.UTF8.GetBytes(message);
|
||||
|
||||
channel.BasicPublish(exchange: string.Empty,
|
||||
routingKey: "hello",
|
||||
basicProperties: null,
|
||||
body: body);
|
||||
Console.WriteLine($" [x] Sent {message}");
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
14
tasks/mikhailov-ys/lab_4/tut1/Send/Send.csproj
Normal file
14
tasks/mikhailov-ys/lab_4/tut1/Send/Send.csproj
Normal file
@@ -0,0 +1,14 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
32
tasks/mikhailov-ys/lab_4/tut2/Task/Task.cs
Normal file
32
tasks/mikhailov-ys/lab_4/tut2/Task/Task.cs
Normal file
@@ -0,0 +1,32 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.QueueDeclare(queue: "task_queue",
|
||||
durable: true,
|
||||
exclusive: false,
|
||||
autoDelete: false,
|
||||
arguments: null);
|
||||
|
||||
var message = GetMessage(args);
|
||||
var body = Encoding.UTF8.GetBytes(message);
|
||||
|
||||
var properties = channel.CreateBasicProperties();
|
||||
properties.Persistent = true;
|
||||
|
||||
channel.BasicPublish(exchange: string.Empty,
|
||||
routingKey: "task_queue",
|
||||
basicProperties: properties,
|
||||
body: body);
|
||||
Console.WriteLine($" [x] Sent {message}");
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
|
||||
static string GetMessage(string[] args)
|
||||
{
|
||||
return ((args.Length > 0) ? string.Join(" ", args) : "Урок 2");
|
||||
}
|
||||
14
tasks/mikhailov-ys/lab_4/tut2/Task/Task.csproj
Normal file
14
tasks/mikhailov-ys/lab_4/tut2/Task/Task.csproj
Normal file
@@ -0,0 +1,14 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
38
tasks/mikhailov-ys/lab_4/tut2/Worker/Worker.cs
Normal file
38
tasks/mikhailov-ys/lab_4/tut2/Worker/Worker.cs
Normal file
@@ -0,0 +1,38 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.QueueDeclare(queue: "task_queue",
|
||||
durable: true,
|
||||
exclusive: false,
|
||||
autoDelete: false,
|
||||
arguments: null);
|
||||
|
||||
channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for messages.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += (model, ea) =>
|
||||
{
|
||||
byte[] body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
Console.WriteLine($" [x] Received {message}");
|
||||
|
||||
int dots = message.Split('.').Length - 1;
|
||||
Thread.Sleep(dots * 1000);
|
||||
|
||||
Console.WriteLine(" [x] Done");
|
||||
|
||||
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
|
||||
};
|
||||
channel.BasicConsume(queue: "task_queue",
|
||||
autoAck: false,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
14
tasks/mikhailov-ys/lab_4/tut2/Worker/Worker.csproj
Normal file
14
tasks/mikhailov-ys/lab_4/tut2/Worker/Worker.csproj
Normal file
@@ -0,0 +1,14 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
24
tasks/mikhailov-ys/lab_4/tut3/EmitLogs/EmitLogs.cs
Normal file
24
tasks/mikhailov-ys/lab_4/tut3/EmitLogs/EmitLogs.cs
Normal file
@@ -0,0 +1,24 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);
|
||||
|
||||
var message = GetMessage(args);
|
||||
var body = Encoding.UTF8.GetBytes(message);
|
||||
channel.BasicPublish(exchange: "logs",
|
||||
routingKey: string.Empty,
|
||||
basicProperties: null,
|
||||
body: body);
|
||||
Console.WriteLine($" [x] Sent {message}");
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
|
||||
static string GetMessage(string[] args)
|
||||
{
|
||||
return ((args.Length > 0) ? string.Join(" ", args) : "info: третий туториал");
|
||||
}
|
||||
14
tasks/mikhailov-ys/lab_4/tut3/EmitLogs/EmitLogs.csproj
Normal file
14
tasks/mikhailov-ys/lab_4/tut3/EmitLogs/EmitLogs.csproj
Normal file
@@ -0,0 +1,14 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<OutputType>Exe</OutputType>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.4.0" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
31
tasks/mikhailov-ys/lab_4/tut3/ReceiveLogs/ReceiveLogs.cs
Normal file
31
tasks/mikhailov-ys/lab_4/tut3/ReceiveLogs/ReceiveLogs.cs
Normal file
@@ -0,0 +1,31 @@
|
||||
using System.Text;
|
||||
using RabbitMQ.Client;
|
||||
using RabbitMQ.Client.Events;
|
||||
|
||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
||||
using var connection = factory.CreateConnection();
|
||||
using var channel = connection.CreateModel();
|
||||
|
||||
channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);
|
||||
|
||||
// declare a server-named queue
|
||||
var queueName = channel.QueueDeclare().QueueName;
|
||||
channel.QueueBind(queue: queueName,
|
||||
exchange: "logs",
|
||||
routingKey: string.Empty);
|
||||
|
||||
Console.WriteLine(" [*] Waiting for logs.");
|
||||
|
||||
var consumer = new EventingBasicConsumer(channel);
|
||||
consumer.Received += (model, ea) =>
|
||||
{
|
||||
byte[] body = ea.Body.ToArray();
|
||||
var message = Encoding.UTF8.GetString(body);
|
||||
Console.WriteLine($" [x] {message}");
|
||||
};
|
||||
channel.BasicConsume(queue: queueName,
|
||||
autoAck: true,
|
||||
consumer: consumer);
|
||||
|
||||
Console.WriteLine(" Press [enter] to exit.");
|
||||
Console.ReadLine();
|
||||
14
tasks/mikhailov-ys/lab_4/tut3/ReceiveLogs/ReceiveLogs.csproj
Normal file
14
tasks/mikhailov-ys/lab_4/tut3/ReceiveLogs/ReceiveLogs.csproj
Normal file
@@ -0,0 +1,14 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
<OutputType>Exe</OutputType>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="RabbitMQ.Client" Version="6.4.0" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
Reference in New Issue
Block a user