Свързани публикации 'stream'


Разпределени съобщения с ниска латентност с RocketMQ — Част 2
Това е втората и заключителна част от блога — разпределени съобщения с ниска латентност с RocketMQ. Ще хвърлим светлина върху трите ключа за гарантиране на капацитета, архитектурата на RocketMQ и бъдещето или системата за съобщения на Alibaba Cloud. Три ключа за гарантиране на капацитет Гаранцията за оптимизация с ниска латентност може да не доведе непременно до ситуация без латентност за машина за съобщения. За да осигури гладко изживяване за приложенията, системата за съобщения..

Свързани въпроси 'stream'

Как да взаимодействам с този ‹File› обект в node.js поток?
Използвам gulp, за да създам поток от glob-съвпадащи файлове и да ги преместя всички, в тяхната вложена структура, на ново място. За да направя това, първо исках да създам прост "през" поток, за да видя какво ще ми бъде предадено, ако препратя към...
20289 изгледи
schedule 21.09.2022

Имам нужда от проверка на входове/изходи с proc_open
#Сценарий: Изпълнявам кодове в python от proc_open, използвайки py.exe. Ex: proc_open('py.exe file.py', $descriptorspec, $pipes, null, null) Моят код на Python може да има вход или изход в недефинирана последователност. Ex: a =...
23 изгледи
schedule 17.09.2022

Как да създадете zip файл с два изходни потока (работа с JSF)
Имам два изходни потока (попълнени с данни от отчети на jasper за генериране на един excel и един csv). Попълването на изходните потоци работи добре, но сега трябва да опаковам и двата „потока/файла“ в zip, за да бъдат изтеглени. Как бих могъл да...
1321 изгледи
schedule 26.09.2022

Как да предавате поток за отговор в hapi.js
Търся паралелния метод в hapi // Express + Request exmaple function(req, res){ request('http://example.com/image.png').pipe(res); } Как да препратя отговор в hapi? server.route({ method: "*", path: "/api/results/{date}", handler:...
7009 изгледи
schedule 27.09.2022

Как да направите аудио предаване на живо
Трябва да излъча аудиосъдържание към мрежата, да го получа и възпроизвеждам в браузъра „в движение“. Аудио съдържанието е само списък от mp3 файлове. и от страна на клиента трябва да изглежда като безкраен аудио поток без състояние. Нещо като...
1526 изгледи
schedule 25.09.2022

Грешка: Не може да се оцени израз, тъй като кодът е оптимизиран или естествена рамка е в горната част на стека за повиквания
Получавам следното изключение в c#: Не мога да оценя израз, тъй като кодът е оптимизиран или естествена рамка е в горната част на стека за повиквания При извикване на метод ReadToEnd() от четец на потоци в уеб приложение. Ако копирам и поставя...
4681 изгледи
schedule 02.10.2022

Обработка на последователност по двойки за сравняване на db таблици
Помислете за следния случай на употреба: Искам да обходя паралелно 2 db таблици и да намеря разлики и пропуски/липсващи записи във всяка таблица. Да приемем, че 1) pk на таблицата е Int ID поле; 2) таблиците се четат в ID ред; 3) може да липсват...
153 изгледи
schedule 02.10.2022

Бъдещето не е пълно?
object Executor extends App { implicit val system = ActorSystem() implicit val materializer = ActorMaterializer() implicit val ec = system.dispatcher import akka.stream.io._ val file = new File("res/AdviceAnimals.tsv") import...
4328 изгледи
schedule 29.09.2022

Предаване на обект на поток към функция, където потокът може да бъде конзолата или файл
Искам да напиша функция, която приема аргумент на потока. В идеалния случай бих искал този аргумент да бъде конзолата (ако искам изходът да отиде на екрана) или файл (ако искам да запазя изхода). Нещо като това: void myFunc(<some stream...
3261 изгледи
schedule 10.10.2022

vlc SAP откриване с помощта на плъгин за браузър
Имам инсталиран плъгин vlc за браузъра chrome. Получавам SAP излъчвания, които обикновено мога да използвам и възпроизвеждам с помощта на самостоятелното vlc приложение. Искам да знам дали същото е възможно с помощта на плъгина vlc. Ако не, мога ли...
381 изгледи
schedule 08.10.2022

Странна внезапна грешка Броят байтове за запис е по-голям от зададената ContentLength
Качвам растерни изображения в Azure Blob Storage. Всичко работеше добре, но след това направих нов проект, за да използвам същия код, но сега постоянно получавам тази грешка „Броят байтове за запис е по-голям от указаната ContentLength“ Ето част...
1783 изгледи
schedule 08.10.2022

Защо изходът от подпроцеса е в грешен ред?
Имам програма на Java, която изпълнява sh в интерактивен режим като подпроцес. Входът се копира от System.in , а изходът се копира в System.out . Всичко работи добре, с изключение на това, че когато изпълнявате команди като pwd в тази...
473 изгледи
schedule 09.12.2022

std::ofstream, проверете дали файлът съществува преди запис
Внедрявам функция за запазване на файлове в приложение Qt , използвайки C++. Търся начин да проверя дали избраният файл вече съществува, преди да пиша в него, така че да мога да изпратя предупреждение към потребителя. Използвам std::ofstream...
78827 изгледи
schedule 24.11.2022

Има ли начин да прочетете входния поток за определен период от време?
Имам ситуация, при която нишка отваря telnet връзка към целеви m/c и чете данните от програма, която изплюва всички данни в своя буфер. След като всички данни бъдат изчистени, целевата програма отпечатва маркер. Темата ми продължава да търси този...
1222 изгледи
schedule 02.12.2022

Изображението не се сервира в jsp от Servlets
Имам jsp, в който за всеки ред от таблицата трябва да покажа изображението, присъстващо в базата данни. Извличам всички данни от реда на таблицата от базата данни, включително изображението като Blob, и го съхранявам в bean. Изображението се...
1157 изгледи
schedule 18.11.2022

java сокет. Как сървърът да знае, че клиентът затваря потока
Искам да напиша сокет-програма за прехвърляне на файл в java. Но имам проблем, как да отменя при прехвърляне на файл. когато затворя inputstream в клиента, как сървърът да го знае, за да затвори outputstream. ето моят код: Клиент...
825 изгледи
schedule 28.10.2022

Достъп до необработени данни за тялото на http заявка
Опитвам се да внедря уеб приложение, използвайки play framework като заместител на старата реализация на http сървър, която взаимодейства със стария наследен http клиент без браузър. Този клиент е написан на Delphi и публикува данни директно в...
1476 изгледи
schedule 05.12.2022

DataOutputStream вътрешно запазване на целия буфер?
В следния код. Чета файл в малък буфер ( len=CHUNK_SIZE) И просто искам да запиша този буфер в изходния поток. Но въпреки че промивам след всяко парче, получавам изключение за препълване на купчина. Е, ако искам да предавам поточно малки файлове,...
223 изгледи
schedule 02.11.2023

Изпращане на големи данни през уеб услуга на Java
Имам уеб услуга на Java, която връща голямо количество данни. Има ли стандартен начин за поточно предаване на отговор, вместо да се опитвате да върнете огромна част от данните наведнъж?
6254 изгледи
schedule 04.11.2022

Как мога да напиша MemoryStream в байт []
Възможен дубликат: Създаване на байтов масив от поток Опитвам се да създам текстов файл в паметта и да го запиша byte[] . Как мога да направя това? public byte[] GetBytes() { MemoryStream fs = new MemoryStream();...
104570 изгледи
schedule 28.11.2022