kmp/mq.cl at master · MBcode/kmp · GitHub

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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
;; Simple client server
(ql 'zeromq)
;; from http://www.cliki.net/cl-zmq but w/edits to try to get it to load bobak@balisp.org
;;need: http://web.archive.org/web/*/http://www.cs.rice.edu/~froydnj/lisp/packer.tar.gz
(al 'packer)
(ql 'iterate) ;still some problems here
(use-package :iterate)
;could write a defpackage

(defun server ()
  "Bind to socket and wait to receive a message.  After receipt,
  return the message \"OK\"."
  (zmq:with-context (ctx 1)
    (zmq:with-socket (socket ctx zmq:rep)
      (zmq:bind socket "tcp://lo:5555")
      (loop
       (let ((query (make-instance 'zmq:msg)))
         (zmq:recv socket query)
         (format t "Recieved query: '~A'~%"
                 (zmq:msg-data-as-string query) ))
       (zmq:send socket (make-instance 'zmq:msg :data "OK")) ))))

(defun client ()
  "Connects to a socket and passes a message and waits to receive the
  \"OK\" from the server."
  (zmq:with-context (ctx 1)
    (zmq:with-socket (socket ctx zmq:req)
      (zmq:connect socket "tcp://localhost:5555")
      (zmq:send socket (make-instance 'zmq:msg
                                      :data "SELECT * FROM mytable" ))
      (let ((result (make-instance 'zmq:msg)))
        (zmq:recv socket result)
        (format t "Recieved string: '~A'~%"
                (zmq:msg-data-as-string result) )))))

;; Publish/subscribe example (uses _(iterate) and _(packer))

(defun publisher ()
  (zmq:with-context (ctx 1)
    (zmq:with-socket (socket ctx zmq:pub)
      (zmq:bind socket "tcp://lo:5555")
      (iter (for msg-id from 0)
      ;iterate:iter (iterate:for msg-id iterate:from 0)
            (zmq:send
             socket
             (make-instance
              'zmq:msg
              :data (coerce (packer:pack ">L" msg-id)
                            '(vector (unsigned-byte 8)) )))))))

(defun subscriber ()
  (zmq:with-context (ctx 1)
    (zmq:with-socket (socket ctx zmq:sub)
      (zmq:setsockopt socket zmq:subscribe "")
      (zmq:connect socket "tcp://localhost:5555")
      (loop
        (let ((query (make-instance 'zmq:msg)))
          (zmq:recv socket query)
          (let ((msg-id (first (packer:unpack
                                ">L" (zmq:msg-data-as-array query) ))))
            (when (= 0 (mod msg-id 10000))
              (print msg-id) )))))))
;Component PACKER not found -fix