Публикации по теме '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