Публикации по теме 'netty'


Netty Learning Journey — — — Иллюстрированная модель Netty Threading
Модель потоков Netty Иллюстрированная модель многопоточности Netty Когда дело доходит до модели потоков Netty, мы должны повторить модель потоков Reactor master-slave. Модель многопоточности Netty в основном основана на реализации модели Reactor master-slave. Модель многопоточности Netty будет расширена из следующих двух диаграмм: Модель потока Reactor master-slave public void bind(int port) throws Exception { EventLoopGroup bossGroup = new NioEven |..

Путь обучения Netty — анализ исходного кода Netty
Базовая структура данных выделения пула памяти (PoolArena, PoolChunk, PoolSubpage) 1. Базовая структура данных распределения памяти Netty Netty предварительно запрашивает большой блок непрерывной памяти (представленный классом PoolArena), а затем каждый PoolArena содержит ряд фрагментов, представленных PoolChunk…

Apple SwiftNIO, Netty, Vert.x, gRPC и Service Mesh
Быстрый тест новой среды сетевых приложений Apple SwiftNIO, управляемой событиями, с размышлениями о платформах Kitura / Vapor / Perfect evolution и Service Mesh, таких как Istio. Сегодня Apple выпустила SwiftNIO , кроссплатформенную платформу для асинхронных событийно-управляемых сетевых приложений с открытым исходным кодом для быстрой разработки обслуживаемых высокопроизводительных протокольных серверов и клиентов, и я немедленно провожу быстрый тест, чтобы убедиться, что он готов к..

Вопросы по теме 'netty'

Высококонкурентный HTTP с Netty и NIO
Я работаю через пример кода HTTP-клиента Netty , чтобы выполнять HTTP-запросы в параллельной многопоточной среде. Однако моя система полностью ломается (за множеством исключений) при довольно низкой пропускной способности. В почти псевдокоде:...
13493 просмотров
schedule 14.11.2023

Как лучше указать Protobuf для использования с Netty (предпочтительно с использованием встроенной поддержки protobuf)
Я указываю протокол в буферах протокола . Транспортный уровень использует поддержку буферов протоколов Netty . netty.io/docs/3.2.6.Final/xref/org/jboss/netty/handler/codec/protobuf/ProtobufDecoder.html" rel="noreferrer"...
5728 просмотров
schedule 26.03.2023

Тупик при использовании netty с Apache Camel
у меня серьезная проблема. У меня есть ситуация, когда мне нужно отправить несколько сообщений в netty, которые все генерируются верблюдом в одном месте, а затем получить ответ на каждое сообщение. Код примерно такой: from("direct:status")...
896 просмотров
schedule 26.04.2023

Как реализовать ботов с помощью netty
Я работаю с netty уже несколько месяцев, и у меня есть большой вопрос. Я пытаюсь создать MMO-игру и хочу, чтобы неигровые персонажи (NPC) могли перемещаться по игре, реагировать на реальное взаимодействие с пользователем (а также быть видимыми для...
387 просмотров
schedule 23.05.2023

Поддержка запросов Range на чистом HTTP-сервере
Можно ли создать конвейер, поддерживающий запросы диапазона ? В качестве альтернативы, может ли кто-нибудь указать мне на части API, на которые мне следует обратить внимание, если я хочу реализовать такую ​​​​поддержку самостоятельно? (по мотивам...
1135 просмотров
schedule 02.04.2023

Как использовать сообщение без пересылки на остальную часть конвейера
У меня есть обработчик на моем сервере, который ищет конкретный экземпляр входящего сообщения, и когда он приходит, обработчик устанавливает внутренний атрибут. Поскольку мне больше не нужно входящее сообщение, я не хочу отправлять его вверх по...
1129 просмотров
schedule 19.12.2022

Использование Netty ChannelLocal
JavaDocs для Netty объясняет, что ChannelLocal похож на ThreadLocal, однако у меня есть несколько вопросов по поводу его использования. ThreadLocal — это статический класс со статическими методами, которые обращаются к объектам, специфичным для...
4767 просмотров
schedule 27.07.2023

Создайте сетевой сервер для передачи сообщений для обработки, а затем отправьте ответы обратно.
Я создаю POC, когда у меня есть сервер, который принимает запросы от клиентов. Затем помещает эти запросы в пул, в котором другой пул потоков обрабатывает эти запросы и возвращает их в выходной пул. Сервер должен принять ответ из пула и отправить...
470 просмотров
schedule 24.12.2022

JBoss netty: Как интегрировать Telnet-соединение в отдельный поток?
Я работаю над веб-приложением, которое соединяет ограниченное количество устройств Android (150) через WebSockets в закрытой сетевой среде на основе jboss netty. Серверу netty также необходимо пересылать команды через telnet в другую систему, поэтому...
444 просмотров
schedule 06.03.2024

Как обрабатывать разные (url) соединения веб-сокетов в netty
Пример Websocket в netty (примеры) имеет обработчик HTTP-запросов, который: выполняет рукопожатие (сначала) (затем) обрабатывает различные типы фреймов WebSocket, в конечном итоге «TextWebSocketFrame». В этом примере есть только один...
2220 просмотров
schedule 20.12.2023

Работа с фрагментацией в Netty
Я разрабатываю двоичный протокол для связи клиент/сервер с использованием Netty, и количество отправленных байтов не является фиксированным и может быть произвольным размером. Клиент отправляет что-то вроде этого: первые 4 байта представляют...
2361 просмотров
schedule 24.01.2023

Поддержка Netty Adaptive UDP Multicast
Новички, у которых возникают проблемы с обработкой видеопотока UDP с помощью Netty 3.2.4. На разных машинах мы видим отброшенные байты и т. д., используя Netty. У нас есть небольшой счетчик после того, как Netty получает байты, чтобы увидеть,...
2075 просмотров
schedule 01.11.2022

Возможно ли несколько ChannelPipelineFactory для транспорта UDP в Netty?
В Netty, если я создам несколько экземпляров ConnectionlessBootstrap , а затем установлю на них ChannelPipeline с помощью кода, например udpBootstrap.setPipeline(pipelineFactory.getPipeline()); Будут ли созданы DatagramChannel с использованием...
310 просмотров
schedule 05.07.2022

exceptionCaught обработка ошибок ответа на запись вызывает исключение и бесконечный цикл вызова exceptionCaught
Я пытаюсь обобщить обработку ошибок для HTTP-запросов и всегда отвечаю фактическим HTTP-кодом ошибки и соответствующим сообщением. Вот моя проблема: в моем обработчике, который расширяет SimpleChannelUpstreamHandler, exceptionCaught запускается,...
2528 просмотров
schedule 03.10.2022

Как я могу непрерывно передавать данные через netty?
Я хотел бы передавать данные RTP через сокет пользователям по требованию. Я хотел бы передавать объем данных каждые 100 миллисекунд. Сначала я думаю, что смогу сделать это с помощью Netty. Однако у меня проблема в том, что когда я пишу данные через...
1197 просмотров
schedule 18.06.2023

в netty мы можем только записывать и получать данные меньше 1024 байт: как мы можем писать или получать больше?
При записи 2048 байтов в обработчик метод messageRevieved должен вызываться дважды, чтобы получить все данные... как я могу получить данные 2048 байт в Код Сервер: public class Server{ public static void main(String[] args){...
9675 просмотров
schedule 25.01.2023

Netty — поделиться вложением между каналами
Я хочу поделиться объектом примерно между 20 каналами в Netty через вложение. бывший.. SharedStatsObj sso ... ChannelFuture future = bootstrap.connect(new InetSocketAddress(host, port)); ChannelHandlerContext c =...
394 просмотров
schedule 04.05.2024

[NETTY]: сопоставление URL-адреса с методом
Я использую netty и пытаюсь реализовать простой HTTP-сервер для некоторого API. Пока у меня есть входящие запросы, я могу получить путь url = /foo/bar/other/. Как я могу сопоставить путь к следующему? class = foo method = bar param = other...
1689 просмотров
schedule 08.10.2022

Netty — инициирование нового соединения с тем же адресом прослушивания, что и связанный канал сервера
У меня есть связанный канал сервера, который в настоящее время принимает соединения по локальному адресу «x». Теперь мне нужно инициировать соединение с удаленным адресом «y», но мне также нужно, чтобы мой локальный адрес прослушивания был «x». При...
455 просмотров
schedule 27.12.2022

Модель с одним потоком на канал с netty OIO
Означает ли модель «один поток на канал» с Netty OIO, что операция записи или чтения может выполняться на одном канале за раз? Я пишу распределенные приложения с небольшим количеством подключений (~ 20) и думал об использовании Netty OIO. Однако мне...
636 просмотров
schedule 10.03.2023