NetCoreServer/examples/ProtoServer/Program.cs at master · devdev22plus/NetCoreServer · GitHub

Repository navigation

History

186 lines (150 loc) · 5.89 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

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

using System;

using System.Net;

using System.Net.Sockets;

using NetCoreServer;

using com.chronoxor.simple;

using com.chronoxor.simple.FBE;

namespace ProtoServer

{

public class SimpleProtoSessionSender : Sender, ISenderListener

{

public SimpleProtoSession Session { get; }

public SimpleProtoSessionSender(SimpleProtoSession session) { Session = session; }

public long OnSend(byte[] buffer, long offset, long size)

{

return Session.SendAsync(buffer, offset, size) ? size : 0;

}

public class SimpleProtoSessionReceiver : Receiver, IReceiverListener

{

public SimpleProtoSession Session { get; }

public SimpleProtoSessionReceiver(SimpleProtoSession session) { Session = session; }

public void OnReceive(DisconnectRequest request) { Session.OnReceive(request); }

public void OnReceive(SimpleRequest request) { Session.OnReceive(request); }

}

public class SimpleProtoSession : TcpSession

{

public SimpleProtoSessionSender Sender { get; }

public SimpleProtoSessionReceiver Receiver { get; }

public SimpleProtoSession(TcpServer server) : base(server)

{

Sender = new SimpleProtoSessionSender(this);

Receiver = new SimpleProtoSessionReceiver(this);

}

protected override void OnConnected()

{

Console.WriteLine($"TCP protocol session with Id '{Id}' connected to remote address '{(Socket.RemoteEndPoint as IPEndPoint)?.Address}' and port {(Socket.RemoteEndPoint as IPEndPoint)?.Port}");

// Send invite notification

SimpleNotify notify = SimpleNotify.Default;

notify.Notification = "Hello from Simple protocol server! Please send a message or '!' to disconnect the client!";

Sender.Send(notify);

}

protected override void OnDisconnected()

{

Console.WriteLine($"TCP protocol session with Id '{Id}' disconnected");

}

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

{

Receiver.Receive(buffer, offset, size);

}

protected override void OnError(SocketError error)

{

Console.WriteLine($"TCP protocol session with Id '{Id}' caught a socket error: {error}");

}

// Protocol handlers

public void OnReceive(DisconnectRequest request) { Disconnect(); }

public void OnReceive(SimpleRequest request)

{

Console.WriteLine($"Received: {request}");

// Validate request

if (string.IsNullOrEmpty(request.Message))

{

// Send reject

SimpleReject reject = SimpleReject.Default;

reject.id = request.id;

reject.Error = "Request message is empty!";

Sender.Send(reject);

return;

}

// Send response

SimpleResponse response = SimpleResponse.Default;

response.id = request.id;

response.Hash = (uint)request.Message.GetHashCode();

response.Length = (uint)request.Message.Length;

Sender.Send(response);

}

public class SimpleProtoSender : Sender, ISenderListener

{

public SimpleProtoServer Server { get; }

public SimpleProtoSender(SimpleProtoServer server) { Server = server; }

public long OnSend(byte[] buffer, long offset, long size)

{

Server.Multicast(buffer, offset, size);

return size;

}

public class SimpleProtoServer : TcpServer

{

public SimpleProtoSender Sender { get; }

public SimpleProtoServer(IPAddress address, int port) : base(address, port)

{

Sender = new SimpleProtoSender(this);

}

protected override TcpSession CreateSession() { return new SimpleProtoSession(this); }

protected override void OnStarted()

{

Console.WriteLine($"Simple protocol server with Id '{Id}' started!");

}

protected override void OnStopped()

{

Console.WriteLine($"Simple protocol server with Id '{Id}' stopped!");

}

protected override void OnError(SocketError error)

{

Console.WriteLine($"Simple protocol server with Id '{Id}' caught an error: {error}");

}

class Program

{

static void Main(string[] args)

{

// Simple protocol server port

int port = 4444;

if (args.Length > 0)

port = int.Parse(args[0]);

Console.WriteLine($"Simple protocol server port: {port}");

Console.WriteLine();

// Create a new simple protocol server

var server = new SimpleProtoServer(IPAddress.Any, port);

// Start the server

Console.Write("Server starting...");

server.Start();

Console.WriteLine("Done!");

Console.WriteLine("Press Enter to stop the server or '!' to restart the server...");

// Perform text input

for (;;)

{

string line = Console.ReadLine();

if (string.IsNullOrEmpty(line))

break;

// Restart the server

if (line == "!")

{

Console.Write("Server restarting...");

server.Restart();

Console.WriteLine("Done!");

continue;

}

// Multicast admin notification to all sessions

SimpleNotify notify = SimpleNotify.Default;

notify.Notification = "(admin) " + line;

server.Sender.Send(notify);

}

// Stop the server

Console.Write("Server stopping...");

server.Stop();

Console.WriteLine("Done!");

}

NetCoreServer/examples/ProtoServer/Program.cs at master · devdev22plus/NetCoreServer · GitHub

Repository navigation

Expand file tree

Breadcrumbs

Program.cs

Latest commit

History

Breadcrumbs

Program.cs

File metadata and controls