NetCoreServer/performance/HttpTraceClient/Program.cs at master · chronoxor/NetCoreServer · GitHub

History

171 lines (148 loc) · 5.79 KB

Raw

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

using System;

using System.Collections.Generic;

using System.Net.Sockets;

using System.Threading;

using NetCoreServer;

using NDesk.Options;

namespace HttpTraceClient

{

class HttpTraceClient : HttpClient

{

public HttpTraceClient(string address, int port, int messages) : base(address, port)

{

_messages = messages;

}

public void SendMessage() { SendRequestAsync(Request.MakeTraceRequest("/")); }

protected override void OnConnected()

{

for (long i = _messages; i > 0; i--)

SendMessage();

}

protected override void OnSent(long sent, long pending)

{

_sent += sent;

base.OnSent(sent, pending);

}

protected override void OnReceived(byte[] buffer, long offset, long size)

{

_received += size;

Program.TimestampStop = DateTime.UtcNow;

Program.TotalBytes += size;

base.OnReceived(buffer, offset, size);

}

protected override void OnReceivedResponse(HttpResponse response)

{

if (response.Status == 200)

Program.TotalMessages++;

else

Program.TotalErrors++;

SendMessage();

}

protected override void OnReceivedResponseError(HttpResponse response, string error)

{

Console.WriteLine($"Response error: {error}");

Program.TotalErrors++;

SendMessage();

}

protected override void OnError(SocketError error)

{

Console.WriteLine($"Client caught an error with code {error}");

Program.TotalErrors++;

}

private long _sent = 0;

private long _received = 0;

private long _messages = 0;

}

class Program

{

public static DateTime TimestampStart = DateTime.UtcNow;

public static DateTime TimestampStop = DateTime.UtcNow;

public static long TotalErrors;

public static long TotalBytes;

public static long TotalMessages;

static void Main(string[] args)

{

bool help = false;

string address = "127.0.0.1";

int port = 8080;

int clients = 100;

int messages = 1;

int seconds = 10;

var options = new OptionSet()

{

{ "h|?|help", v => help = v != null },

{ "a|address=", v => address = v },

{ "p|port=", v => port = int.Parse(v) },

{ "c|clients=", v => clients = int.Parse(v) },

{ "m|messages=", v => messages = int.Parse(v) },

{ "z|seconds=", v => seconds = int.Parse(v) }

};

try

{

options.Parse(args);

}

catch (OptionException e)

{

Console.Write("Command line error: ");

Console.WriteLine(e.Message);

Console.WriteLine("Try `--help' to get usage information.");

return;

}

if (help)

{

Console.WriteLine("Usage:");

options.WriteOptionDescriptions(Console.Out);

return;

}

Console.WriteLine($"Server address: {address}");

Console.WriteLine($"Server port: {port}");

Console.WriteLine($"Working clients: {clients}");

Console.WriteLine($"Working messages: {messages}");

Console.WriteLine($"Seconds to benchmarking: {seconds}");

Console.WriteLine();

// Create HTTP clients

var httpClients = new List<HttpTraceClient>();

for (int i = 0; i < clients; i++)

{

var client = new HttpTraceClient(address, port, messages);

// client.OptionNoDelay = true;

httpClients.Add(client);

}

TimestampStart = DateTime.UtcNow;

// Connect clients

Console.Write("Clients connecting...");

foreach (var client in httpClients)

client.ConnectAsync();

Console.WriteLine("Done!");

foreach (var client in httpClients)

while (!client.IsConnected)

Thread.Yield();

Console.WriteLine("All clients connected!");

// Wait for benchmarking

Console.Write("Benchmarking...");

Thread.Sleep(seconds * 1000);

Console.WriteLine("Done!");

// Disconnect clients

Console.Write("Clients disconnecting...");

foreach (var client in httpClients)

client.DisconnectAsync();

Console.WriteLine("Done!");

foreach (var client in httpClients)

while (client.IsConnected)

Thread.Yield();

Console.WriteLine("All clients disconnected!");

Console.WriteLine();

Console.WriteLine($"Errors: {TotalErrors}");

Console.WriteLine();

Console.WriteLine($"Total time: {Utilities.GenerateTimePeriod((TimestampStop - TimestampStart).TotalMilliseconds)}");

Console.WriteLine($"Total data: {Utilities.GenerateDataSize(TotalBytes)}");

Console.WriteLine($"Total messages: {TotalMessages}");

Console.WriteLine($"Data throughput: {Utilities.GenerateDataSize((long)(TotalBytes / (TimestampStop - TimestampStart).TotalSeconds))}/s");

if (TotalMessages > 0)

{

Console.WriteLine($"Message latency: {Utilities.GenerateTimePeriod((TimestampStop - TimestampStart).TotalMilliseconds / TotalMessages)}");

Console.WriteLine($"Message throughput: {(long)(TotalMessages / (TimestampStop - TimestampStart).TotalSeconds)} msg/s");

}

NetCoreServer/performance/HttpTraceClient/Program.cs at master · chronoxor/NetCoreServer · GitHub

Expand file tree

Breadcrumbs

Program.cs

Latest commit

History

Breadcrumbs

Program.cs

File metadata and controls