1 package org.sim0mq.demo;
2
3 import org.djutils.serialization.SerializationException;
4 import org.sim0mq.Sim0MQException;
5 import org.sim0mq.message.Sim0MQMessage;
6 import org.zeromq.SocketType;
7 import org.zeromq.ZContext;
8 import org.zeromq.ZMQ;
9
10
11
12
13
14
15
16
17
18 public final class Client
19 {
20
21 private Client()
22 {
23
24 }
25
26
27
28
29
30
31 public static void main(final String[] args) throws Sim0MQException, SerializationException
32 {
33 ZContext context = new ZContext(1);
34
35
36 System.out.println("Connecting to server...");
37
38 ZMQ.Socket requester = context.createSocket(SocketType.REQ);
39 requester.connect("tcp://localhost:5556");
40
41
42
43
44 Object[] request = new Object[] { "test message", new Double(14.2), new Float(-28.4), new Short((short) 10) };
45 requester.send(Sim0MQMessage.encodeUTF8(true, "IDVV14.2", "MC.1", "MM1.4", "TEST.2", 1201L, request),
46 0);
47
48 byte[] reply = requester.recv(0);
49 Object[] replyMessage = Sim0MQMessage.decode(reply).createObjectArray();
50 System.out.println("Received\n" + Sim0MQMessage.print(replyMessage));
51
52 requester.close();
53 context.destroy();
54 context.close();
55 }
56
57 }