twjitm core

twjitm-ядро

Сопутствующее введение в бизнес

Система сетевой инфраструктуры Netty

Загрузка информации Netty используется для реализации системы связи в реальном времени с длинным соединением. Клиент может использоваться в любом сценарии и поддерживает связь по http в реальном времени, связь по веб-сокетам, связь по протоколу TCP, связь по протоколу udp, широковещательный протокол и т. д. Протокол http и протокол RPC. Используйте собственную структуру сетевых пакетов для реализации собственного сетевого стека.

1: Поддержка распределенного Zookeeper для настройки сервисного узла.
2. Реализовать стек протоколов личных сообщений Netty в виде пользовательских аннотаций.
3: Поддержка удаленных вызовов RPC.
4: Поддержка Redis.
5: Поддержка разделения БД.
6: Поддержка синхронной и асинхронной обработки сообщений.
7. Поддержка модели поставок/потребления очереди сообщений Kafka для реализации распределенной очереди сообщений.
8: Поддержка зашифрованной передачи данных для обеспечения безопасности данных.
9: Поддержка отправки распределенных транзакций 3pc и отката исключений.

Преимущественно используемые бизнес-сценарии

1: Игровой сервер
2: Система связи в реальном времени
3: Система обработки финансовых данных
4. Системы с высокими требованиями к производительности сети в реальном времени.
5: Общие интернет-системы

Сейчас на стадии обновления

Независимый модуль базы данных, независимый модуль транзакций, независимый модуль планирования потоков. Предоставляйте сетевые сервисы в виде микросервисов.

Режим TCP-связи

TCP-связь, используя netty для реализации TCP-связи, вы можете использовать comtwjitmcorestartGameService в проекте, изменить режим запуска на режим запуска tcp-сервера, вы можете использовать testjavacomtwjitmClientServiceTest в тест для имитации клиентов. Для подключения вам необходимо изменить порт и адрес TCP-сервера для подключения. Обработка сообщений TCP использует очереди сообщений для помещения всех входящих сообщений в очередь и обработки сообщений с помощью технологии объединения потоков.

Режим связи UDP

Формат пользовательского стека сетевых протоколов UDP аналогичен формату пользовательского стека сетевых протоколов TCP. Разница в том, что UDP не требует установления соединения, что является режимом связи без сохранения состояния. В модуле обработки сообщений сеанс сохраняется при использовании. TCP-соединение используется для определения того, какой это клиент. Протокол UDP может правильно обрабатывать сообщения, отправленные клиентом, в двух различных режимах обработки сообщений, включая: режим синхронной очереди;

Режим HTTP-связи

Протокол HTTP также реализован с использованием специального стека сетевых протоколов, который аналогичен протоколам TCP и UDP, за исключением того, что пакеты данных отличаются. HTTP — это протокол, построенный на прикладном уровне TCP. Используйте синхронную обработку для своевременной обработки сообщений по мере их поступления.

Режим связи RPC

Модуль RPC разделен на синхронные вызовы и асинхронные вызовы, вызовы удаленного сервера, использование netty для реализации облегченной структуры сервера RPC и настройку стратегий концессии потоков. В сочетании с базовыми знаниями Java, такими как динамический прокси, реализован модуль связи с сервером rpc. Используйте документы XML для настройки базовой информации о сервере RPC для достижения динамического горизонтального расширения сервера. Выполните базовую подготовку для распределенных серверов.

услуги смотрителя зоопарка

За счет интеграции Zookeeper, служб динамической регистрации, служб обнаружения и интеграции логики RPC реализуются обнаружение и регистрация распределенных служб.

сервис кафки

Путем интеграции сервисов Kafka. Реализуйте распределенные очереди сообщений сервера и отделите логику в системе.

другой

Все еще оптимизируем, оптимизируем пространственную сложность, временную сложность, время отклика, возможности стресс-тестирования и другие характеристики проекта.

Использование весеннего контейнера

В этом проекте Spring используется для единообразного управления некоторыми bean-компонентами. При запуске сервера инициализация контейнера равномерно передается Spring. Используя аннотации, предоставляемые Spring, можно легко получить объекты bean-компонентов, внедренные в контейнер Spring, и улучшить читаемость. код.

средство обновления событий

Благодаря управлению потоками обновления событий сервера используют независимый режим для обновления событий сервера и режим очереди для последовательного выполнения событий.

Автор: Не подбирайте хороший ник случайно twjitm qq: 1089718215

Адрес блога https://blog.csdn.net/baidu_23086307

Адрес личного сайта https://twjitm.com;