-
Notifications
You must be signed in to change notification settings - Fork 8
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Example: SubscriberWithEvents (#148)
- Loading branch information
1 parent
eeac24c
commit ab49e83
Showing
4 changed files
with
140 additions
and
13 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,76 @@ | ||
| namespace SubscriberWithEvents; | ||
|
|
||
| using System.Text; | ||
| using System.Text.Json; | ||
| using HiveMQtt.Client; | ||
| using HiveMQtt.Client.Options; | ||
| using HiveMQtt.MQTT5.Types; | ||
|
|
||
| public class Program | ||
| { | ||
| public static bool ExitRequested { get; set; } | ||
| public static int MessageCount { get; set; } | ||
| public static int PublishesReceivedCount { get; set; } | ||
|
|
||
| public static async Task Main(string[] args) | ||
| { | ||
| MessageCount = 0; | ||
| PublishesReceivedCount = 0; | ||
|
|
||
| // Subscribe to the CancelKeyPress event | ||
| Console.CancelKeyPress += (sender, e) => | ||
| { | ||
| // Handle Ctrl+C (SIGINT) by setting exitRequested flag | ||
| e.Cancel = true; // Prevent process termination | ||
| ExitRequested = true; | ||
| Console.WriteLine("Ctrl+C (SIGINT) received. Press Ctrl+C again to exit immediately."); | ||
| }; | ||
|
|
||
| var options = new HiveMQClientOptions | ||
| { | ||
| Host = "127.0.0.1", | ||
| Port = 1883, | ||
| CleanStart = true, | ||
| ClientId = "SubscriberWithEvents", | ||
| }; | ||
|
|
||
| var client = new HiveMQClient(options); | ||
|
|
||
| // Message Handler | ||
| // | ||
| // It's important that this is setup before we connect to the broker | ||
| // otherwise queued messages that are sent down may be lost. | ||
| // | ||
| client.OnMessageReceived += (sender, args) => | ||
| { | ||
| MessageCount++; | ||
| }; | ||
|
|
||
| // client.OnPublishReceived += (sender, args) => | ||
| // { | ||
| // PublishesReceivedCount++; | ||
| // }; | ||
|
|
||
| // Connect to the broker | ||
| var connectResult = await client.ConnectAsync().ConfigureAwait(false); | ||
| if (connectResult.ReasonCode != HiveMQtt.MQTT5.ReasonCodes.ConnAckReasonCode.Success) | ||
| { | ||
| throw new IOException($"Failed to connect: {connectResult.ReasonString}"); | ||
| } | ||
|
|
||
| // Subscribe to a topic | ||
| var topic = "load/test/1"; | ||
| var subscribeResult = await client.SubscribeAsync(topic, QualityOfService.ExactlyOnceDelivery).ConfigureAwait(false); | ||
| Console.WriteLine($"Subscribed to {topic}: {subscribeResult.Subscriptions[0].SubscribeReasonCode}"); | ||
|
|
||
| var message_number = 0; | ||
| while (!ExitRequested) | ||
| { | ||
| await Task.Delay(1000).ConfigureAwait(false); | ||
| Console.WriteLine($"Received {MessageCount} msgs/sec"); | ||
| // Console.WriteLine($"Received {MessageCount} msgs/sec & {PublishesReceivedCount} publishes/sec"); | ||
| MessageCount = 0; | ||
| PublishesReceivedCount = 0; | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,3 @@ | ||
| # SubscriberWithEvents | ||
|
|
||
| Example app that I used to measure subscription event processing. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,14 @@ | ||
| <Project Sdk="Microsoft.NET.Sdk"> | ||
|
|
||
| <PropertyGroup> | ||
| <OutputType>Exe</OutputType> | ||
| <TargetFramework>net8.0</TargetFramework> | ||
| <ImplicitUsings>enable</ImplicitUsings> | ||
| <Nullable>enable</Nullable> | ||
| </PropertyGroup> | ||
|
|
||
| <ItemGroup> | ||
| <ProjectReference Include="..\..\Source\HiveMQtt\HiveMQtt.csproj" /> | ||
| </ItemGroup> | ||
|
|
||
| </Project> |