![Network
觜襯 豌襴襯 觜蠍 IO
4
var socket = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.IPv4);
// preprocess socket
var buffer = new byte[4096];
socket.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None,
result => {
var received = socket.EndReceive(result);
// process packet
}, null /* state */);](https://image.slidesharecdn.com/csharpserver-140613015431-phpapp02/85/C-Game-Server-4-320.jpg)
![TaskCompletionSource
C++ Future + C# Task Awaitable Future
5
Network
static Task<int> ReceiveAsync(this Socket sock, byte[] buf, int off, int size)
{
var source = new TaskCompletionSource<int>(sock);
sock.BeginReceive(buf, off, size, SocketFlags.None, state =>
{
try
{
source.SetResult(socket.EndReceive(state));
}
catch (Exception e)
{
source.SetException(e);
}
}, source);
return source.Task;
}](https://image.slidesharecdn.com/csharpserver-140613015431-phpapp02/85/C-Game-Server-5-320.jpg)
![async, await
Task.Result 觜蠍 蠍(await), 蠏碁 貊螳 (async)
6
Network
static async Task<byte[]> ReceiveAsync(this Socket socket, int count)
{
var buffer = new byte[count];
var length = 0;
do
{
var num = await ReceiveAsync(socket, buffer, length, count);
if (num == 0)
break;
length += num;
count -= num;
} while (count > 0);
if (length != buffer.Length) throw new IOException("packet is truncated.");
return buffer;
}](https://image.slidesharecdn.com/csharpserver-140613015431-phpapp02/85/C-Game-Server-6-320.jpg)
;
}
}
await 讌 讌 IO signal る, 企 Task 覃豢螻,
螳 るジ Task襯 谿場](https://image.slidesharecdn.com/csharpserver-140613015431-phpapp02/85/C-Game-Server-7-320.jpg)
![Attribute
Runtime 蠏 螳ロ metadata襯 貊 譯殊
16
Database
[CommandHandler("npc", "襦 Npc襯 燕")]
internal bool SpawnNpc(Entity admin,
[CommandArgument("Npc 企")] string npcName,
[CommandArgument("Npc X 豺", 0)] double newX,
[CommandArgument("Npc Y 豺", 0)] double newY)
{
if (!admin.Has<Pos>())
return false;
var npc = EntityManager.Instance.Create(EntityTemplate.Ids.Npc);
npc.Get<Motion>().Dir = admin.Get<Motion>().Dir;
npc.Get<Nameplate>().Name = npcName;
npc.Get<Pos>().Assign(new Pos {X = newX, Y = newY});
覈轟伎 る 貊 蠍磯
語 る螻 蠍磯蓋 螳, type 貊 蠍磯](https://image.slidesharecdn.com/csharpserver-140613015431-phpapp02/85/C-Game-Server-16-320.jpg)
![Summary
async, await 蠍一 Network(IO) 襦蠏碁覦
dynamic Runtime type dispatch
Reflection, Attribute襯 boiler plate 貊 譴願鍵
Attribute襦 metadata襯 貊襦 蠍磯 讌 覲伎 觜 譴願鍵
coroutine 蠍一 襦讌 襦蠏碁覦
24
覲企 , 蠏碁Μ螻 讌蟯(蠍一) 貊朱 讌 覲伎 觜 譴願鍵
焔 覓語 襦 覦 願屋 譴 蟆 [...]](https://image.slidesharecdn.com/csharpserver-140613015431-phpapp02/85/C-Game-Server-24-320.jpg)
C# Game Server
- 1. C# Server 襷り鍵 2013. 06. 07. 豕
- 2. Why? 觜 2 async await extension method linq Observable TPL DynamicObject Reflection Attribute IEnumerable
- 4. Network 觜襯 豌襴襯 觜蠍 IO 4 var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IPv4); // preprocess socket var buffer = new byte[4096]; socket.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, result => { var received = socket.EndReceive(result); // process packet }, null /* state */);
- 5. TaskCompletionSource C++ Future + C# Task Awaitable Future 5 Network static Task<int> ReceiveAsync(this Socket sock, byte[] buf, int off, int size) { var source = new TaskCompletionSource<int>(sock); sock.BeginReceive(buf, off, size, SocketFlags.None, state => { try { source.SetResult(socket.EndReceive(state)); } catch (Exception e) { source.SetException(e); } }, source); return source.Task; }
- 6. async, await Task.Result 觜蠍 蠍(await), 蠏碁 貊螳 (async) 6 Network static async Task<byte[]> ReceiveAsync(this Socket socket, int count) { var buffer = new byte[count]; var length = 0; do { var num = await ReceiveAsync(socket, buffer, length, count); if (num == 0) break; length += num; count -= num; } while (count > 0); if (length != buffer.Length) throw new IOException("packet is truncated."); return buffer; }
- 7. async, await 7 Network async void ReceiveLoop(Socket socket) { while (true) { var lengthBytes = await socket.ReceiveAsync(sizeof (int)); var packetBytes = await socket.ReceiveAsync( BitConverter.ToInt32(lengthBytes, 0)); // process packet var packet = ReadPacket(packetBytes); _handlerMap[packet.GetType()](packet); } } await 讌 讌 IO signal る, 企 Task 覃豢螻, 螳 るジ Task襯 谿場
- 8. Listener (Server) ClientSocket 觜蠍磯 Accept伎, 螳 Socket襷 觜蠍磯 Packet 蠍壱伎 豌襴 8 Network var listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); var localEndPoint = new IPEndPoint(IPAddress.Any, Port); listener.Bind(localEndPoint); listener.Listen(100); while (true) { var clientSocket = await listener.AcceptAsync(); ReceiveLoop(clientSocket); } async method
- 9. Summary Socket Async 螻 襯 (.NET 企 IOCP襦 豌襴) async, await TaskContinuation Syntax sugar async, await Keyword襦 Callback ｸ蟆 Network 貊 蠏碁覃伎 Thread Pool 朱 (.NET Thread Pool 企 IOCP襦 蟯襴) 9 Network
- 10. Datasheet dynamic 朱 Xml 所鍵 code generator襯 10 Xml Xml Model 蟲 Xml Parser 蟲 code generator DynamicObject XmlDefinition ( ) general-loader
- 11. DynamicObject RuntimeType朱 朱 覃る 蠏 螳 覦襯 Type 螳 覩碁Μ 譴觜伎 覩襦 XmlDefinition 11 Datasheet public class XmlObject : DynamicObject { private readonly Dictionary<string, object> _attributes; private readonly Dictionary<string, IEnumerable<XmlObject>> _multipleChildren; private readonly Dictionary<string, XmlObject> _singleChildren; public override bool TryGetMember(GetMemberBinder binder, out object result) { return TryGetValue(_attributes, binder.Name, out result) || TryGetValue(_singleChildren, binder.Name, out result) || TryGetValue(_multipleChildren, binder.Name, out result); }
- 12. DynamicObject Attribute襯 曙 Type 覲 覩碁Μ dynamic朱 蠏狩 Model 蠏 螳 12 Datasheet _attributes = element.Attributes.OfType<XmlAttribute>() .ToDictionary(e => e.Name, e => defNode.SelectAttribute(e.Name) .ReadValue(e.Value)); <?xml version="1.0" encoding="utf-8" ?> <World> <Config port="40123"/> </World> World.Config@port : int dynamic world = XmlObject.Load("World.xml", _def); _listener.Port = world.Config.port;
- 13. Summary dynamic 貊 螳 豢(Model, Parser 覿) ろ襦 誤 蠏 覦 Runtime 螳 XmlDefinition ( 螳) 覲企 觜襯 襯 蟆曙一 Model, Parser襯 Generate (IVsSingleFileGenerator) 13 Datasheet
- 14. Database Reflection螻 Attribute 朱 朱 Bind 蟲 scheme 覿 蟆曙 model 焔朱 覈 蟲 願屋 螳 14 Scheme DataModel Bind 蟲 nosql or generator Reflection
- 15. Reflection Runtime model type覲企 scheme襯 蟲豢 螳 一危一 Serialize/Deserialize 蟲 (String螻 object 覲) 覈 Model 螳豌企ゼ Xml襦 覲 15 Database new XElement("Objects", _gameObjects.Values.Select( obj => new XElement("Object", obj.GetType().GetProperties() .Where(e => e.CanRead && e.CanWrite) .Select(e => new XAttribute(e.Name, SerializeValue(e.PropertyType, e.GetValue(obj, null)) ))))); 覈 Property 豢 豢ロ string朱, 曙 れ object襦
- 16. Attribute Runtime 蠏 螳ロ metadata襯 貊 譯殊 16 Database [CommandHandler("npc", "襦 Npc襯 燕")] internal bool SpawnNpc(Entity admin, [CommandArgument("Npc 企")] string npcName, [CommandArgument("Npc X 豺", 0)] double newX, [CommandArgument("Npc Y 豺", 0)] double newY) { if (!admin.Has<Pos>()) return false; var npc = EntityManager.Instance.Create(EntityTemplate.Ids.Npc); npc.Get<Motion>().Dir = admin.Get<Motion>().Dir; npc.Get<Nameplate>().Name = npcName; npc.Get<Pos>().Assign(new Pos {X = newX, Y = newY}); 覈轟伎 る 貊 蠍磯 語 る螻 蠍磯蓋 螳, type 貊 蠍磯
- 17. Summary model 螳豌伎 type 覲企ゼ 豕 Attribute襯 覿 螳ロ 襷 覲企ゼ 貊 譯殊 (DSL, 覓語, 譯殊 碁 覲企 豢螳 讌 覲伎螳 ) Dirty Lazy襯 豕 螳 覲企 觜襯 襯 蟆曙一 Code Generate襯 (partial class襯 貊 狩 螳) 17 Database
- 18. Logic yield return State Machine 蟇 context 讌襯 覲 貊 18 A B C 1豐 3豐 5豐 Logic Engine Logic #1 Logic #2
- 19. IEnumerable (Coroutine) IEnumerable 覦 type朱 れ yield return れ 襦讌 蟾讌 蠍 螳 覦 19 Logic public IEnumerable<int> RegenerateEntry() { while (true) { var newNpc = _context.NewGameObject(ObjectType.Npc); _context.AddGameObject(newNpc); _context.BroadcastPacket(newNpc.ToSpawnPacket()); var newAi = new EachAi(this, newNpc); _context.AddEntry(newAi.AiLogicEntry); var nextInterval = _random.Next(interval) + base; yield return nextInterval; } 願 語蟆 願 れ 語 讌覿
- 20. IEnumerator (Coroutine) IEnumerator MoveNext() 襦 貊 ろ Current襦 yield return 蟆郁骸 螳 20 Logic var enumerator = RegenerateEntry().GetEnumerator(); while (enumerator.MoveNext()) { Thread.Sleep(enumerator.Current); } IEnumerable襦覿 IEnumerator襯 螳語 MoveNext()襦 yield 蟲螳 貊 yield return 覦 螳 詞. 蠍 螳襷 IEnumerator襯 蟯襴螻 Thread.Sleep() 覲企 襦
- 21. LogicEngine (Coroutine) 21 Logic public void EntryLoop() { var prev = DateTime.Now; while (true) { var now = DateTime.Now; var delta = (now - prev).Milliseconds; foreach (var newOne in _newLogicEntries) { var newEntry = new LogicEntry { Enumerator = newOne().GetEnumerator(), SleepTime = 0 }; _logicEntries.Add(newEntry); } _newLogicEntries.Clear(); 襦 豢螳 Entry襦覿 IEnumerator螳豌企ゼ
- 22. LogicEngine (Coroutine) 22 Logic var removals = new List<LogicEntry>(); foreach (var each in _logicEntries) { each.SleepTime -= delta; if (each.SleepTime >= 0) continue; if (!each.Enumerator.MoveNext()) removals.Add(each); else each.SleepTime = each.Enumerator.Current; } _logicEntries.RemoveAll(removals.Contains); prev = now; const int logicInterval = 16; Thread.Sleep(logicInterval); } } 螳ロ IEnumerator 讌 螳 襦讌 谿場 ろ 襦讌 螳 return 襭覃 MoveNext()螳 fasle襯 覦 襭 襦讌
- 23. Summary IEnumerable螻 yield return 譟壱朱 coroutine 蟲 螳 coroutine伎襷 襷 boiler plate 貊 螳 yield return朱 襷 覲企ゼ れ (Unity3D Engine) Thread螳 LogicEngine Entry 覿 螳 ( Thread螳 蟆曙 Lfe 螳豌企 蠍壱 螻り ) Script襯 C#朱 (?) (c# script + roslyn + linqpad + nuget) 23 Logic
- 24. Summary async, await 蠍一 Network(IO) 襦蠏碁覦 dynamic Runtime type dispatch Reflection, Attribute襯 boiler plate 貊 譴願鍵 Attribute襦 metadata襯 貊襦 蠍磯 讌 覲伎 觜 譴願鍵 coroutine 蠍一 襦讌 襦蠏碁覦 24 覲企 , 蠏碁Μ螻 讌蟯(蠍一) 貊朱 讌 覲伎 觜 譴願鍵 焔 覓語 襦 覦 願屋 譴 蟆 [...]
- 25. How much faster is C++ than C#? 25 C# may not be faster, but it makes YOU/ME faster. That's the most important measure for what I do. :) http://stackoverflow.com/questions/138361/how-much-faster-is-c-than-c