際際滷

Mono is Dead
゛互堀なC#サ�`バを朕峺して゛

もくじ
? Introduction
? 遺#で1嵐遺鉛庄艶稼岳を案く
? Mono is Dead

やったこと
? １��１で��蕕垢�
? TCPの
? ゲ�`ムサ�`バを
? C#(Mono)で恬った

�Y惚
? １サ�`バあたり10,000クライアント殻業
ならいける
? �o並iOSとAndroidにリリ�`スして、ちゃ
んと�咾い討�

�Lく逗しい�蕕い世辰拭�
? 逗しかったのは麼にMonoのせい
? 書晩はMonoをdisります
? が、その念に念戻岑�R�async/await��
猟�の慌嗤をします

Q&A
? なんでC#なの�
? クライアントがC#(Unity)で��譴�
いて、匯何のロジックを慌嗤したかっ
た

Q&A
? P2Pでやらないのはなぜ�
? 個ざんに��する�I崔がゲ�`ムサ�`バ恬
るよりめんどそう

Q&A
? .NET Framework聞わないの�
? 安庄稼糸看敬壊を塰喘するのはとてもつらい

Q&A
? なんでTCPなの�UDPじゃだめなの�
? UDPはつらい
? パケット�Mみ羨てるのつらい
? 壅僕佚�I尖を�g廾するのつらい
? 僕佚圷を�R�eするのつらい
? 俳僅�返�弔蕕�

遺#で1嵐遺鉛庄艶稼岳を案く

C#でTCP宥佚
? お�}: 5バイトのデ�`タを鞭け函り、そ
のデ�`タをそのまま卦すサ�`バを恬ろ
う
? つまり喪晒井掘界鞄看サ�`バ

揖豚井
TcpClient client = // Accept何蛍は福待
Stream stream = client.GetStream();
while (true) {
var buf = new buf[5];
stream.Read(buf, 0, buf.Length);
stream.Write(buf, 0, buf.Length);
}

ダメ
? Readでbuf.Lengthだけ�iめる隠�^は�oい
? Readの��､�0の�rは�K極だったりエ
ラ�`の��呂覆里農�發鰺兇欧�
? 箭翌の�I尖をしよう

揖豚井�個�
static void ReadFully(this Stream stream, byte[] buf) {
var readBytes = 0;
while (readBytes != buf.Length) {
var n = stream.Read(buf, readBytes,
buf.Length - readBytes);
if (n == 0)
throw new Exception("hoge-");
readBytes += n;
}
}

揖豚井�個�
try {
while (true) {
stream.ReadFully(buf);
}
} catch (Exception e) {
// 箭翌竃たらログを火して俊�Aを�]じる
logger.Error("error", e);
client.Close();
}

��g
? 揖豚議に��里呂箸討盧��g
? 箭翌�I尖を根めても��g

だがしかし
CPUが畠く�Pいてない

だがしかし
? 柵び竃したスレッドが峭まる
? 8スレッドで�咾�靴��蓮�8クライアントが
Readするだけで畠何峭まる
? たかだかスレッド方までしかクライアントを
案けない

スレッド��やせば�
? メモリが怎りない
? スタック�I囃だけで恷詰256KBぐらい
? コンテキストスイッチで�r�gが�譴��
? なので1嵐クライアントをスレッドで案くのは
きつい
? いわゆるC10K��}

つまり
? １嵐クライアントをスレッドで揖豚�I
尖するのは�o尖

そこで
? 掲揖豚�I尖
? C#には掲揖豚�I尖喘の�v方がある
? BeginRead, EndRead, BeginWrite, EndWrite
? これを聞えば盾�Qできるはず

揖豚井�壅��
try {
while (true) {
stream.ReadFully(buf);
}
client.Close();
}

掲揖豚井
var buf = new byte[5];
Func<IAsyncResult> func;
func = ar1 => {
stream.EndReadFully(ar1);
stream.BeginWrite(buf, 0, buf.Length, ar2 => {
stream.EndWrite(ar2);
// 壅業BeginReadを兵める�whileル�`プ�輝�
stream.BeginReadFully(buf, 0, buf.Length, func,
null);
};
};
stream.BeginReadFully(buf, 0, buf.Length, func, null);
頼畠に�eコ�`ド

掲揖豚井
func = ar1 => {
null);
};
};
どうやって�g廾するのか蛍かりませんでした

掲揖豚井
func = ar1 => {
stream.EndReadFully(ar1); // 箭翌�I尖どうしよう
stream.EndWrite(ar2); // 箭翌�I尖どうしよう
null);
};
};
箭翌�I尖つらい

掲揖豚井
func = ar1 => {
null);
};
};
whileル�`プすら壅｢とか´

�Y�
? 掲揖豚�I尖はつらい

そこで
? async/await��猟
? C# 5.0 で秘った仟しい掲揖豚�I尖

揖豚井�壅��
static void ReadFully(
this Stream stream, byte[] buf) {
var readBytes = 0;
var n = stream.Read(buf, readBytes,
buf.Length - readBytes);
if (n == 0)
readBytes += n;
}
}

async/await井
static async Task ReadFullyAsync(
var readBytes = 0;
var n = await stream.ReadAsync(buf, readBytes,
buf.Length - readBytes)
.ConfigureAwait(false);
if (n == 0)
readBytes += n;
};
}

餓蛍
static async Task ReadFullyAsync(
var readBytes = 0;
var n = await stream.ReadAsync(buf, readBytes,
buf.Length - readBytes)
if (n == 0)
readBytes += n;
};
}

async/await井
try {
while (true) {
await stream.ReadFullyAsync(buf)
await stream.WriteAsync(buf, 0, buf.Length)
}
client.Close();
}

餓蛍
try {
while (true) {
}
client.Close();
}

async/awaitは措い
? 揖豚井とほぼ揖じように��韻�
? 箭翌�I尖も��gに��韻�

�g縞の強き
? スレッドの旗わりにタスクと柵ばれる
�g了で�嘛�垢�
? タスク徭悶はメモリをほぼ聞わない
? いわゆる�X楚スレッド
? awaitする業にタスクを�I尖するスレッ
ドが�笋錣�

�g縞の強き
try {
while (true) {
}
client.Close();
}
Thread1
Thread2

�g縞の強き
タスク９��の��

Q&A
? Con?gureAwait(false)って採�
? これが�oいと、頼阻宥岑枠が駅ず柵
び竃し圷のスレッドになる
? UI�I尖する��呂榔秬獷世韻鼻▲�
レッド棋ちで�Wくなるし、デッドロッ
クが軟きる辛嬬來もある

async/awaitは措い
? 揖豚井とほぼ揖じように��韻�
? 箭翌�I尖も��gに��韻�
? メモリをほとんど聞わない (new!)
? CPUを聞いきれる (new!)
? つまり1嵐クライアント案ける

温壊霞稼界/温敬温庄岳まとめ
? async/awaitを聞って
? 互堀で
? ��④笋垢�
? C#サ�`バ
? これは´いける�

温壊霞稼界/温敬温庄岳まとめ

Mono is Dead
゛云�兵まるよ�゛

.NET is Alive
? MicrosoftVisual C#を聞って�g廾
? VC#を聞っている�r泣ではほぼ��}な
く�g廾できてた

Mono is Dead
? VC#ではうまく�咾い討い�exeをMonoで
�g佩すると´

Mono is Dead
? VC#ではうまく�咾い討い�exeをMonoで
�g佩すると´
�繁繁繁繁繁繁�
�?融隼の棒?�
�Y^Y^Y^Y^Y�

LogicalSetData で棒ぬ
? System.Runtime.Remoting.Messaging.CallC
ontext.LogicalSetData
? TLS(Thread Local Storage)のタスク井み
たいなやつ�屎�_には�`うけど�
? タスク�g了のグロ�`バル�篳�辰櫃い�
を恬りたい��蓮△海譴鮪mるしか�oい
�はず�

? VC#では��}なく�咾い討い燭里法�
Monoだとおかしな�嘛�鬚垢�
? 珂看稼看のソ�`スコ�`ドを靖めてみると´

[ThreadStatic] static Hashtable logicalDatastore;
static void LogicalSetData(string name, object data)
{
var r = logicalDatastore;
if (r == null)
r = logicalDatastore = new Hashtable();
r[name] = data;
}
Mono-3.2.8のソ�`スより

[ThreadStatic] static Hashtable logicalDatastore;
static void LogicalSetData(string name, object data)
{
var r = logicalDatastore;
if (r == null)
r = logicalDatastore = new Hashtable();
r[name] = data;
}
ただのTLS�g廾になっている
そんな�g廾で寄嬋健か�
Mono-3.2.8のソ�`スより

? Issueにも�鷂罎�
れている
? Mono 4.0參週で
岷っていること
が蛍かった

? タスク�g了のグロ�`バル�篳�鯤垢��
栽はMono 4.0參週が駅�
? Mono 4.0は2015定5埖4晩にリリ�`ス
? 巷塀パッケ�`ジに秘ってない辛嬬來が
あるので�櫃鬚弔韻茲�

? �Y�: Mono 3.x は棒ぬべき

キャンセルト�`クンで棒ぬ

? ReadAsyncやWriteAsyncなどの掲揖豚�I
尖を嶄僅する�C嬬
? 麼にタイムアウトの�蕕吠垢�

public virtual Task<int> ReadAsync(
byte[] buffer,
int offset,
int count,
CancellationToken cancellationToken)
// Task1
CancellationToken token = tokenSource.Token;
await stream.ReadAsync(buf, 0, size, token);
// Task2
// ReadAsyncの�I尖を嶄僅させる
tokenSource.Cancel();

? これでいけそうに�える
? が、�g�HはI/O�I尖を嶄僅できない
? NetworkStreamがキャンセルト�`クンに
��鬉靴討覆�
? え、タイムアウトどうやって�g�Fする
の�

? Stack Over?ow垰く
? 仝タイムアウトになったら�eタスクで
Closeすりゃ嶄僅できるよ々
? これなら´いける�

�Y^Y^Y^Y^Y�

static async Task TestConnect() {
try {
var client = new TcpClient();
var task = Task.Run(
() => client.ConnectAsync("localhost", 8080));
client.Close();
await task.ConfigureAwait(false);
} catch (Exception) { }
}
これを１０嵐指ぐらい柵び竃すと寄悶棒ぬ
畠悶コ�`ド

? そもそもNetworkStreamは碧��議にはス
レッドセ�`フではない
? なので棒ぬのは碧圭がないという�櫃�
する
? そしてタイムアウト�g�Fは尅り竃しに
��

? �Y蕉キュ�`に�めて匯云晒することで
採とかした

? ReadAsyncやCloseをリクエストキュ�`
に�めて、
? ワ�`カ�`タスクがそれを�I尖し、
? �Y惚をリプライキュ�`に�めたのを、
? 柵び竃し圷がリプライキュ�`の�Y惚を
�iむ

public async Task<int> ReadAsync(
byte[] buf, int offset, int length,
CancellationToken token) {
// リクエストキュ�`に�めて
await requestQueue.Enqueue(new Request() {
Type = Operation.ReadAsync,
Buf = buf,
Offset = offset,
Length = length,
}).ConfigureAwait(false);
// レスポンスキュ�`に�Y惚が卦ってくるのを棋つ
var resp = await responseQueue.Dequeue(token)
return resp.ReadResult;
}

Buf = buf,
Offset = offset,
Length = length,
}
responseQueueがCancellationTokenに��鬉靴討譴个い�

async void Run() {
while (true) {
// リクエストを鞭け函り
var op = await requestQueue.Dequeue().ConfigureAwait(false);
// リクエスト�阿�I尖をして
switch (op.Type) {
case Operation.ReadAsync:
var result = await client.ReadAsync(
op.Buf, op.Offset, op.Length).ConfigureAwait(false);
// レスポンスを卦す
await responseQueue.Enqueue(resp)
break;
case Operation.WriteAsync:
...
}
}

? キュ�`から１��ずつ函ってきて�I尖す
るので、揖�rにReadAsyncやCloseが柵ば
れたりしない
? responseQueueがキャンセルト�`クンに
��鬉靴討襪里如�o並タイムアウト�I
尖ができるようになった

? �Y�: Monoは宥佚のタイムアウトすら�
�gに��鬉任④覆�

�a怎
? キャンセルト�`クンが聞えないのは
VC#でも揖じ
? ただし�eタスクからCloseを柵び竃しま
くっても鯛ちなかった

Q&A
? これってちゃんとClose柵ばれるの�
? 柵ばれないこともある
? でもソケットはSafeHandleなのでファ
イナライザがうまいことやってくれる

京顎韓韓艶姻京鉛看界一で棒ぬ

Buf = buf,
Offset = offset,
Length = length,
}
requestQueueとresponseQueueはどうやって恬るの�

? Queue<T>はスレッドセ�`フではない
? ConcurrentQueue<T>はawaitで棋てない
? 温壊霞稼界/温敬温庄岳に��鬉靴織⑤紿`が駅勣

? System.Threading.Tasks.Data?ow.BufferBlo
ck が聞えそう
? BufferBlock.SendAsync(data, token)で僕佚
? BufferBlock.ReceiveAsync(token)で鞭佚
? キャンセルト�`クンが聞える�

�Y^Y^Y^Y^Y�

static async Task SendTask(BufferBlock<string> bb) {
for (int i = 0; i < 10000; i++) {
await bb.SendAsync(i.ToString()).ConfigureAwait(false);
await Task.Delay(1).ConfigureAwait(false);
}
}
static async Task ReceiveTask(BufferBlock<string> bb) {
for (int i = 0; i < 10000; i++) {
try {
await bb.ReceiveAsync(TimeSpan.FromMilliseconds(1))
} catch (Exception) { }
}
}
SendTaskとReceiveTaskを揖�rに�g佩すると寄悶棒ぬ
畠悶コ�`ド

? 噸宥にバグ
? ReceiveAsyncのタイムアウト�rの�I尖で
レ�`スコンディション軟こしてる

? �Y蕉徭恬した
? AsyncMutex
? AsyncConditionVariable
? AsyncQueue
? 書のところ��}なく�咾い討�

? �Y�: Monoはまともに聞えないライブ
ラリを戻工している

皆赫艶稼で棒ぬ
? Mono垰く
? SGen is a new and powerful garbage
collector.

�Y^Y^Y^Y^Y�

? しばらく�咾�靴討襪般突擦頬世�
? スタックトレ�`スを�るとSGenの�v方
坪で棒んでる
? new and powerful ェ´

? 硬き措き Boehm GC を聞うと棒ななく
なった
? ただしメモリが4GBまでしか聞えない
? �}方プロセス軟�咾垢襪海箸��

? �Y�: Monoはnew and powerful (丶) な
GCを戻工している

馨馨温沿(鰻或鰻掘)で棒ぬ

�Y^Y^Y^Y^Y�

? しばらく�咾�靴討い襪�
? mmap(...PROT_NONE...) failed
? というエラ�`を竃して棒ぬ

? Issueにあるように、コンパイラのビル
ド�rに-DUSE_MMAPと-DUSE_MUNMAP
を翌す駅勣がある
? Monoをソ�`スからビルドし岷し

? Monoはしばらく�咾�靴討襪抜麑緞世�

メモリリ�`クで棒ぬ
? 隆盾�Q��}
? �塞が�譴�辰討い��呂世吋瓮皀衒�
喘楚が��え�Aける
? ゲ�`ムサ�`バのコ�`ドが��いせいなの
かどうか蛍からない

? PHP�u恬宀垰く:
? 仝�Wなら、10リクエストごとにApache
を壅軟�咾靴泙垢諭��
? ということで、匯協楚�咾�靴燭薀廛�
セスを壅軟�咾垢襪茲Δ砲靴�

? �Y�: Monoはメモリリ�`クを軟こしてい
るかも、と夘伉圧麹になるだけの和仇
がある

まとめ
? Monoは繁�には壼かった
? 肝やるならクライアントをホストにす
ると房う

まとめ
? とはいえ、async/awaitのおかげでサ�`バ
のコ�`ドは�輝玉くなった
? 畠何で5,000佩殻業
? ☆クライアントとの慌宥コ�`ドは茅く
?冱い�Qえれば5,000佩殻業でMonoが棒にま
くったという´

まとめ
? Monoは�繁�gとプロセスが�棒ぬ
? �歴を隔って聞いましょう

際際滷

Mono is Dead

Recommended

More Related Content

What's hot (19)

Viewers also liked (8)

Similar to Mono is Dead (20)

Recently uploaded (8)

Mono is Dead