чччД...
Бывает, что нужно по-другому. Сервер должен оповестить клиентов о каком-то событии.
Клиенты отправляют серверу заявку, что они готовы получать сообщения о наступившем событии ("подписываются" на событие).
Одних клиентов могут интересовать одни события, других - другие.
А сервера вообще не волнует, кому из клиентов что нужно. Сервер - это как бы радиоприемник, вещающий в эфир. Кто слушает - молодец. А кто не слушает - тот ССЗБ.
Такая схема называется "Издатель - Подписчик" (Publisher-Subscriber).
Пример.
Автоматическая метеостанция измеряет температуру, атмосферное давление и скорость ветра. Результаты измерений время от времени (например, после завершения цикла измрений) передаются "всем заинтересованным лицам".
Кого-то интересует всё, кому-то нужна температура, кого-то волнует только скорость ветра.
Пишем код метеостанции (), то есть, сервер-издатель :
Сервер.
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
program PS_Server;
{$APPTYPE CONSOLE}
uses
SysUtils, ZMQ;
var
fContext: Pointer;
fSocket: Pointer;
fDummy: string;
fMsgStr: string;
fMessage: zmq_msg_t;
begin
fContext := zmq_ctx_new();
fSocket := zmq_socket(fContext, ZMQ_PUB);
zmq_bind(fSocket, 'tcp://*:4040');
Writeln('Publisher started...');
Randomize;
while True do begin
Sleep(100); // Типа измеряет что-то
// Температура
fMsgStr := Format('Temperature : %d C', [20 - Random(40)]);
zmq_msg_init(fMessage); // Инициализация zmq_msg_t
zmq_msg_init_size(fMessage, Length(fMsgStr) * SizeOf(Char)); // Резервирование памяти
// Копирование данных из строки в буфер сообщения:
move(PChar(fMsgStr)^, zmq_msg_data(fMessage)^, Length(fMsgStr) * SizeOf(Char));
zmq_msg_send(fMessage, fSocket, 0); // Пересылка
zmq_msg_close(fMessage); // Всё
// Атм. давление
fMsgStr := Format('Pressure : %d Pa', [101375 - Random(100)]);
zmq_msg_init(fMessage);
zmq_msg_init_size(fMessage, Length(fMsgStr) * SizeOf(Char));
move(PChar(fMsgStr)^, zmq_msg_data(fMessage)^, Length(fMsgStr) * SizeOf(Char));
zmq_sendmsg(fSocket, fMessage, 0);
zmq_msg_close(fMessage);
// Скорость ветра
fMsgStr := Format('Wind : %d m/s', [Random(10)]);
zmq_send(fSocket, PChar(fMsgStr)^, Length(fMsgStr) * SizeOf(Char), 0);
end;
zmq_ctx_destroy(fContext);
Readln(fDummy);
end.
все то же самое, что и для работы по шаблону "Запрос - Ответ".
За исключением того сокет создается с опцией ZMQ_PUB (сокет - издатель):
1.
zmq_socket(fContext, ZMQ_PUB);
сервер только отправляет сообщения подписчикам (методы zmq_msg_send, zmq_sendmsg, zmq_send).
Попытка получить данные выбросит исключение.
....
В каждом рабочем цикле отправляется три сообщения (вернее, "публикуется"): о температуре, о давлении и о скорости ветра.
Для разнообразия показаны разные способы формирования сообщений.
