Свързани публикации '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