Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Message callback #32

Merged
merged 2 commits into from
Oct 25, 2022
Merged

Message callback #32

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
c14a8f0
Fixing Indentation.
Tyendinaga Oct 25, 2022
f2c14af
Transfer packet handling into a callback.
Tyendinaga Oct 25, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Mmo Game Framework/MainServer/Program.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,7 @@ _ _____ ______
timeout = 25;
logger.LogInformation($"Setting Server Tick Rate {tickRate}");
if(timeout != 25)
logger.LogInformation($"Setting Server Timeout To {timeout}");
logger.LogInformation($"Setting Server Timeout To {timeout}");
logger.LogInformation("Starting Dragon-Client connections. Port 1337");
// create and start the server
server = new MmoServer(orchestationService, _entityStore, new NetPeerConfiguration("Dragon-Client")
Expand Down
239 changes: 126 additions & 113 deletions Mmo Game Framework/Mmogf.Servers/MmoServer.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,126 @@ public void Start()
var thread1 = new Thread(async () => await Loop());
thread1.Priority = ThreadPriority.AboveNormal;
thread1.Start();

}

private void MessageCallback(object state)
{
NetIncomingMessage im = s_server.ReadMessage();

// Note: This should never happen but I'm not going to bet it won't.
if (im == null)
{
_logger.LogError("Callback with no Message");
return;
}

// handle incoming message
switch (im.MessageType)
{
case NetIncomingMessageType.DebugMessage:
string text = im.ReadString();
_logger.LogDebug(text);
break;
case NetIncomingMessageType.ErrorMessage:
string text2 = im.ReadString();
_logger.LogError(text2);
break;
case NetIncomingMessageType.WarningMessage:
string text3 = im.ReadString();
_logger.LogWarning(text3);
break;
case NetIncomingMessageType.VerboseDebugMessage:
string text4 = im.ReadString();
_logger.LogDebug(text4);
break;
case NetIncomingMessageType.StatusChanged:
NetConnectionStatus status = (NetConnectionStatus)im.ReadByte();

string reason = im.ReadString();
if (_logger.IsEnabled(LogLevel.Debug))
_logger.LogDebug(im.SenderConnection.RemoteUniqueIdentifier + " " + status + ": " + reason);

if (status == NetConnectionStatus.Connected)
{
HandleWorkerConnect(im);
}
else if (status == NetConnectionStatus.Disconnected)
{
_logger.LogInformation($"{_config.AppIdentifier} {im.SenderConnection.RemoteUniqueIdentifier} Disconnected");
WorkerConnection worker;
if (_connections.TryGetValue(im.SenderConnection.RemoteUniqueIdentifier, out worker))
HandleWorkerDisconnect(im, worker);
}

break;
case NetIncomingMessageType.Data:
//if(_logger.IsEnabled(LogLevel.Debug))
// _logger.LogDebug(im.SenderConnection.RemoteUniqueIdentifier +" - '" + BitConverter.ToString(im.Data) + "'");
var simpleData = MessagePackSerializer.Deserialize<MmoMessage>(im.Data);
//if (_logger.IsEnabled(LogLevel.Debug))
// _logger.LogDebug($"Serve Codes {simpleData.MessageId}");

switch (simpleData.MessageId)
{
case ServerCodes.ChangeInterestArea:
var interestArea = MessagePackSerializer.Deserialize<ChangeInterestArea>(simpleData.Info);
WorkerConnection worker;
if (_connections.TryGetValue(im.SenderConnection.RemoteUniqueIdentifier, out worker))
{
worker.InterestPosition = interestArea.Position.ToPosition();

var results = _entities.UpdateWorkerInterestArea(worker);
foreach (var add in results.addEntityIds)
HandleEntitySubChange(worker, true, add);
foreach (var add in results.removeEntityIds)
HandleEntitySubChange(worker, false, add);
Send(im.SenderConnection, new MmoMessage()
{
MessageId = ServerCodes.EntityCheckout,
Info = MessagePackSerializer.Serialize(new EntityCheckout()
{
Checkouts = new List<int>(),
Remove = false,
}),
}, NetDeliveryMethod.ReliableOrdered, 11);
}

break;
case ServerCodes.EntityUpdate:
HandleEntityUpdate(im, simpleData);
break;
case ServerCodes.EntityEvent:
HandleEntityEvent(im, simpleData);
break;
case ServerCodes.EntityCommandRequest:
HandleEntityCommand(im, simpleData);
break;
case ServerCodes.EntityCommandResponse:
HandleEntityCommandResponse(im, simpleData);
break;
case ServerCodes.Ping:
Send(im.SenderConnection, new MmoMessage()
{
MessageId = ServerCodes.Ping,
Info = new byte[0],
});
break;
default:
// incoming chat message from a client
//string chat = im.ReadString();

break;
}

break;
default:
_logger.LogError("Unhandled type: " + im.MessageType + " " + im.LengthBytes + " bytes " + im.DeliveryMethod + "|" + im.SequenceChannel);
break;
}

s_server.Recycle(im);

}

public void Stop()
Expand All @@ -87,124 +206,18 @@ public void Stop()

async Task Loop()
{
// No idea what this does but Lidgren needs it to be happy
SynchronizationContext.SetSynchronizationContext(new SynchronizationContext());

// Register a Callback for Testing
s_server.RegisterReceivedCallback(MessageCallback, SynchronizationContext.Current);

while (s_server.Status != NetPeerStatus.NotRunning)
{
_stopwatch.Restart();
try
{

NetIncomingMessage im;
while ((im = s_server.ReadMessage()) != null)
{
// handle incoming message
switch (im.MessageType)
{
case NetIncomingMessageType.DebugMessage:
string text = im.ReadString();
_logger.LogDebug(text);
break;
case NetIncomingMessageType.ErrorMessage:
string text2 = im.ReadString();
_logger.LogError(text2);
break;
case NetIncomingMessageType.WarningMessage:
string text3 = im.ReadString();
_logger.LogWarning(text3);
break;
case NetIncomingMessageType.VerboseDebugMessage:
string text4 = im.ReadString();
_logger.LogDebug(text4);
break;
case NetIncomingMessageType.StatusChanged:
NetConnectionStatus status = (NetConnectionStatus)im.ReadByte();

string reason = im.ReadString();
if(_logger.IsEnabled(LogLevel.Debug))
_logger.LogDebug(im.SenderConnection.RemoteUniqueIdentifier + " " + status + ": " + reason);

if (status == NetConnectionStatus.Connected)
{
HandleWorkerConnect(im);

}
else if(status == NetConnectionStatus.Disconnected)
{
_logger.LogInformation($"{_config.AppIdentifier} {im.SenderConnection.RemoteUniqueIdentifier} Disconnected");
WorkerConnection worker;
if(_connections.TryGetValue(im.SenderConnection.RemoteUniqueIdentifier, out worker))
HandleWorkerDisconnect(im, worker);
}

break;
case NetIncomingMessageType.Data:
//if(_logger.IsEnabled(LogLevel.Debug))
// _logger.LogDebug(im.SenderConnection.RemoteUniqueIdentifier +" - '" + BitConverter.ToString(im.Data) + "'");
var simpleData = MessagePackSerializer.Deserialize<MmoMessage>(im.Data);
//if (_logger.IsEnabled(LogLevel.Debug))
// _logger.LogDebug($"Serve Codes {simpleData.MessageId}");

switch (simpleData.MessageId)
{
case ServerCodes.ChangeInterestArea:
var interestArea = MessagePackSerializer.Deserialize<ChangeInterestArea>(simpleData.Info);
WorkerConnection worker;
if (_connections.TryGetValue(im.SenderConnection.RemoteUniqueIdentifier, out worker))
{
worker.InterestPosition = interestArea.Position.ToPosition();

var results = _entities.UpdateWorkerInterestArea(worker);
foreach(var add in results.addEntityIds)
HandleEntitySubChange(worker, true, add);
foreach (var add in results.removeEntityIds)
HandleEntitySubChange(worker, false, add);
Send(im.SenderConnection, new MmoMessage()
{
MessageId = ServerCodes.EntityCheckout,
Info = MessagePackSerializer.Serialize(new EntityCheckout()
{
Checkouts = new List<int>(),
Remove = false,
}),
}, NetDeliveryMethod.ReliableOrdered, 11);
}

break;
case ServerCodes.EntityUpdate:
HandleEntityUpdate(im, simpleData);
break;
case ServerCodes.EntityEvent:
HandleEntityEvent(im, simpleData);
break;
case ServerCodes.EntityCommandRequest:
HandleEntityCommand(im, simpleData);
break;
case ServerCodes.EntityCommandResponse:
HandleEntityCommandResponse(im, simpleData);
break;
case ServerCodes.Ping:
Send(im.SenderConnection, new MmoMessage()
{
MessageId = ServerCodes.Ping,
Info = new byte[0],
});
break;
default:
// incoming chat message from a client
//string chat = im.ReadString();

break;
}

break;
default:
_logger.LogError("Unhandled type: " + im.MessageType + " " + im.LengthBytes + " bytes " + im.DeliveryMethod + "|" + im.SequenceChannel);
break;
}
s_server.Recycle(im);
}

//ConnectedWorkersGauge.Set(s_server.ConnectionsCount);


HandleEntitySubChanges();

if(s_server.ConnectionsCount > 0)
Expand Down