[C#] Network

[Sojang]

Драстье
Для шарпа есть сетевые библиотеки?По типу netty на яве

[Alay]

Смотря подочто, если под L2 то я свою написал (асинхронный клиент\сервер)
Хотя подо что угодно можно поставить если учесть что в пакетах первые 2 байта будет размер пакета.(TCP)
для получения логов из библиотеки

Код:

Utils.Logger.InitLogger(OnLogMessage)

        private static void OnLogMessage(LogMessageType logMessageType, string message)
        {
            var biuldedMsg = new StringBuilder();

            switch (logMessageType)
            {
                case LogMessageType.Debug:
                    Console.ForegroundColor = ConsoleColor.Cyan;
                    Console.WriteLine(message);
                    break;
                case LogMessageType.Info:
                    Console.ForegroundColor = ConsoleColor.DarkGreen;
                    Console.WriteLine(message);
                    break;
                case LogMessageType.Warning:
                    Console.ForegroundColor = ConsoleColor.DarkYellow;
                    Console.WriteLine(message);
                    break;
                case LogMessageType.Error:
                    Console.ForegroundColor = ConsoleColor.DarkRed;
                    Console.WriteLine(message);
                    break;
                case LogMessageType.CriticalError:
                    Console.ForegroundColor = ConsoleColor.Red;
                    Console.WriteLine(message);
                    break;
                default:
                    throw new ArgumentOutOfRangeException(nameof(logMessageType), logMessageType, null);
            }
        }

Ну а если не хотите шифровать трафик то просто реализуйте интерфейс ICrypt
таким образом.

Код:

using System;
using Utils.Interface;

namespace Utils.Crypt
{
    public sealed class NonCryptedCrypt: ICrypt
    {
        public bool Decrypt(ref byte[] data, int offset, int size)
        {
            return true;
        }

        public byte[] Encrypt(byte[] data, int offset, int size)
        {
            return data;
        }

        public void UpdateKey(byte[] key)
        {
            throw new NotImplementedException();
        }

        public byte[] GetKey()
        {
            throw new NotImplementedException();
        }

        public void Dispose()
        {
            throw new NotImplementedException();
        }
    }
}

и добавляйте его каждому новому соединению.

PS. нетти - прошлый век (обработка 5000+ соединений в 1 поток сомнительное решение)
при наличии у .net мощнейщего ThreadPool
ИМХО

[n3k0nation]

offtop

нетти - прошлый век (обработка 5000+ соединений в 1 поток сомнительное решение)

Не надо так, пожалуйста. Сначала ознакомьтесь с предметом.

[PROGRAMMATOR]

Sojang, DotNetty.

[Alay]

offtop

Не надо так, пожалуйста. Сначала ознакомьтесь с предметом.

Оффтоп

Я с ним знаком. Суть его знаю. Возможно мое изречение прозвучало громко и беспочвенно.
По сути netty и ему подобное(неблокирующие сокеты\селекторы) было практически единственным решением проблемы 10к коннектов.
Все это было верно, до появления нативного ThreadPool(асинхронности) с продуманной очередью ожидания выполнения.
Но действительно, кто я такой чтоб так говорить)
В любом случае у каждого есть свое мнение. А я считаю так.

Копипаст из одной статьи про ThreadPool в net4+

Новый пул потоков работает немного другим образом. Для каждого рабочего потока в пуле существует своя локальная очередь. Задача, которая попала в локальную очередь, может породить дочернюю и они размещаются в эту же локальную очередь. Также задачи выполняются в локальной очереди в LIFO (last-in-first-out) порядке, в отличие от пула в 3.5, где задачи из глобальной очереди выполняются рабочими потоками в FIFO (first-in-first-out) порядке. Так как только рабочий поток разгребает свою собственную кучу, вернее имеет доступ к ее началу (head), то на уровне локальной очереди не требуется никаких синхронизаций. Поэтому добавление и извлечение задачи из этой очереди происходят очень быстро. Побочным эффектом такого выполнения является то, что очередь разгребается в обратном порядке. Хотя делать какие-то допущения в программе о порядке выполнения задач в очереди нельзя – так как пул потоков своеобразный черный ящик.


Когда рабочий поток видит что делать ему больше нечего, то есть его локальная очередь пустая, он пытается своровать задачу у другого рабочего потока. Но ворует он элементы с хвоста чужой локальной очереди. Такое действие уже требует синхронизации. И производительность немного снизится. Если же все локальные очереди пустые, то рабочий поток попытается забрать задачу из глобальной очереди в FIFO порядке. Если же глобальная очередь окажется пустой, тогда рабочий поток «заснет» пока не появится работа для него. Если рабочий поток проспал слишком много времени и работы так и не получил, он проснется и уничтожится, освободив занимаемые ресурсы.

Почему глобальная очередь на картинке lock-free, если все равно нужна синхронизация для доступа к ней рабочих потоков из пула?. Потому что она действительно lock-free, теперь для синхронизации используются не lock-и (Monitor), а некий аналог interlocked операций и это позволило увеличить быстродействие очереди.

Источник

Небольшое отступление

Вот я честно говоря не понимаю зачем мучится с неблокирующими сокетами(l2j) -
Если прочитали не весь пакет - то оставляем его в очереди и на след тике дочитываем.
Когда TCP гарантирует полную доставку информации и именно в том порядке, в котором они были отправлены. Но так как у нас сокет не блокируется то в момент тика главного потока селектора в буффере может быть не вся информация.
А реакция на пакеты все равно идет в отдельных потоках - runImpl.
Тоесть если взять в пример онлайн в 5000 рыл - что так у вас было бы 5000 потоков.
Что с неблокирующими - 5001. Если считать только сетевую часть.(условно)

Точнее не понимаю зачем мучится сейчас, когда есть асинхронность и в java8 и в net4