program ConsoleServer;

{$APPTYPE CONSOLE}

uses
  SysUtils, ZMQ;
var
  fContext: Pointer;
  fResponder: Pointer;
  fStatus: Cardinal;
  fInValue: Cardinal;
  fOutValue: UInt64;

begin
  fContext := zmq_ctx_new();
  fResponder := zmq_socket(fContext, ZMQ_REP);
  fStatus := zmq_bind(fResponder, 'tcp://*:5555');
  assert(fStatus = 0);
  Writeln('Starting...');
  while (True) do begin
    zmq_recv(fResponder, fInValue, SizeOf(fInValue), 0);
    Writeln('Received: ', fInValue);
    fOutValue := fInValue * fInValue;
    zmq_send(fResponder, fOutValue, SizeOf(fOutValue), 0);
  end;

end.

program ConsoleClient;

{$APPTYPE CONSOLE}

uses
  SysUtils, ZMQ;

const
  c_iter = 999999;
var
  context: Pointer;
  requester: Pointer;
  i: Integer;
  f_ScrValue: Cardinal;
  f_qValue: UInt64;

begin
  Writeln('Client starting...');
  Randomize();

  context := zmq_ctx_new();
  requester := zmq_socket(context, ZMQ_REQ);
  zmq_connect(requester, 'tcp://localhost:5555');

  for i := 0 to c_iter do begin
    f_ScrValue := Random(-1);
    Writeln('Sending ', f_ScrValue);
    zmq_send(requester, f_ScrValue, SizeOf(f_ScrValue), 0);
    zmq_recv(requester, f_qValue, SizeOf(f_qValue), 0);
    Writeln('Received ', f_qValue);
  end;

  zmq_close(requester);
  zmq_ctx_destroy(context);
end.

  zmq_connect(requester, 'tcp://localhost:5555');