Artifact d3bcbb3ac013a8f8898e2ec7b0cb9c8bc188fad7:
- Executable file nanomsg/pubsub — part of check-in [590cb5e905] at 2016-08-17 07:41:06 on branch trunk — nanomsg error handling and other fixes (user: ovenpasta@pizzahack.eu size: 1658)
0000: 23 21 20 2f 75 73 72 2f 62 69 6e 2f 65 6e 76 20 #! /usr/bin/env 0010: 73 63 68 65 6d 65 2d 73 63 72 69 70 74 0a 3b 20 scheme-script.; 0020: 2d 2a 2d 20 6d 6f 64 65 3a 20 73 63 68 65 6d 65 -*- mode: scheme 0030: 20 2d 2a 2d 0a 0a 3b 20 47 65 74 74 69 6e 67 20 -*-..; Getting 0040: 53 74 61 72 74 65 64 20 77 69 74 68 20 27 6e 61 Started with 'na 0050: 6e 6f 6d 73 67 27 0a 3b 20 50 75 62 2f 53 75 62 nomsg'.; Pub/Sub 0060: 0a 3b 20 66 72 6f 6d 20 68 74 74 70 73 3a 2f 2f .; from https:// 0070: 67 69 74 68 75 62 2e 63 6f 6d 2f 64 79 73 69 6e github.com/dysin 0080: 67 65 72 2f 6e 61 6e 6f 6d 73 67 2d 65 78 61 6d ger/nanomsg-exam 0090: 70 6c 65 73 23 63 6f 64 65 2d 33 0a 23 21 63 68 ples#code-3.#!ch 00a0: 65 7a 73 63 68 65 6d 65 0a 0a 28 69 6d 70 6f 72 ezscheme..(impor 00b0: 74 20 28 6e 61 6e 6f 6d 73 67 29 20 28 63 68 65 t (nanomsg) (che 00c0: 7a 73 63 68 65 6d 65 29 29 0a 0a 28 6e 61 6e 6f zscheme))..(nano 00d0: 6d 73 67 2d 6c 69 62 72 61 72 79 2d 69 6e 69 74 msg-library-init 00e0: 29 0a 0a 28 64 65 66 69 6e 65 20 73 65 72 76 65 )..(define serve 00f0: 72 2d 6e 61 6d 65 20 22 73 65 72 76 65 72 22 29 r-name "server") 0100: 0a 28 64 65 66 69 6e 65 20 63 6c 69 65 6e 74 2d .(define client- 0110: 6e 61 6d 65 20 22 63 6c 69 65 6e 74 22 29 0a 0a name "client").. 0120: 28 64 65 66 69 6e 65 20 64 61 74 65 20 64 61 74 (define date dat 0130: 65 2d 61 6e 64 2d 74 69 6d 65 29 0a 0a 28 64 65 e-and-time)..(de 0140: 66 69 6e 65 20 28 73 6c 65 65 70 2d 73 20 73 65 fine (sleep-s se 0150: 63 29 0a 20 20 28 73 6c 65 65 70 20 28 6d 61 6b c). (sleep (mak 0160: 65 2d 74 69 6d 65 20 27 74 69 6d 65 2d 64 75 72 e-time 'time-dur 0170: 61 74 69 6f 6e 20 30 20 73 65 63 29 29 29 0a 0a ation 0 sec))).. 0180: 28 64 65 66 69 6e 65 20 28 73 65 72 76 65 72 20 (define (server 0190: 75 72 6c 29 0a 20 20 28 64 65 66 69 6e 65 20 73 url). (define s 01a0: 6f 63 6b 20 28 6e 6e 2d 73 6f 63 6b 65 74 20 41 ock (nn-socket A 01b0: 46 5f 53 50 20 4e 4e 5f 50 55 42 29 29 0a 20 20 F_SP NN_PUB)). 01c0: 28 64 65 66 69 6e 65 20 65 69 64 20 28 6e 6e 2d (define eid (nn- 01d0: 62 69 6e 64 20 73 6f 63 6b 20 75 72 6c 29 29 0a bind sock url)). 01e0: 20 20 28 6c 65 74 20 6c 6f 6f 70 20 28 29 0a 20 (let loop (). 01f0: 20 20 20 28 6c 65 74 2a 20 28 5b 64 20 28 64 61 (let* ([d (da 0200: 74 65 29 5d 29 0a 20 20 20 20 20 20 28 70 72 69 te)]). (pri 0210: 6e 74 66 20 22 53 45 52 56 45 52 3a 20 50 55 42 ntf "SERVER: PUB 0220: 4c 49 53 48 49 4e 47 20 44 41 54 45 20 7e 64 7e LISHING DATE ~d~ 0230: 6e 22 20 64 29 0a 20 20 20 20 20 20 28 6e 6e 2d n" d). (nn- 0240: 73 65 6e 64 20 73 6f 63 6b 20 28 73 74 72 69 6e send sock (strin 0250: 67 2d 3e 75 74 66 38 20 64 29 20 30 29 0a 20 20 g->utf8 d) 0). 0260: 20 20 20 20 28 73 6c 65 65 70 2d 73 20 31 29 0a (sleep-s 1). 0270: 20 20 20 20 20 20 28 6c 6f 6f 70 29 29 29 0a 20 (loop))). 0280: 20 28 6e 6e 2d 73 68 75 74 64 6f 77 6e 20 73 6f (nn-shutdown so 0290: 63 6b 20 65 69 64 29 29 0a 0a 28 64 65 66 69 6e ck eid))..(defin 02a0: 65 20 28 63 6c 69 65 6e 74 20 75 72 6c 20 6e 61 e (client url na 02b0: 6d 65 29 0a 20 20 28 64 65 66 69 6e 65 20 73 6f me). (define so 02c0: 63 6b 20 28 6e 6e 2d 73 6f 63 6b 65 74 20 41 46 ck (nn-socket AF 02d0: 5f 53 50 20 4e 4e 5f 53 55 42 29 29 0a 20 20 28 _SP NN_SUB)). ( 02e0: 64 65 66 69 6e 65 20 65 69 64 20 23 66 29 0a 20 define eid #f). 02f0: 20 28 6e 6e 2d 73 65 74 73 6f 63 6b 6f 70 74 20 (nn-setsockopt 0300: 73 6f 63 6b 20 4e 4e 5f 53 55 42 20 4e 4e 5f 53 sock NN_SUB NN_S 0310: 55 42 5f 53 55 42 53 43 52 49 42 45 20 30 20 30 UB_SUBSCRIBE 0 0 0320: 29 0a 20 20 28 73 65 74 21 20 65 69 64 20 28 6e ). (set! eid (n 0330: 6e 2d 63 6f 6e 6e 65 63 74 20 73 6f 63 6b 20 75 n-connect sock u 0340: 72 6c 29 29 0a 20 20 28 6c 65 74 20 6c 6f 6f 70 rl)). (let loop 0350: 20 28 29 0a 20 20 20 20 28 6c 65 74 2a 20 28 5b (). (let* ([ 0360: 62 75 66 20 28 62 6f 78 20 23 74 29 5d 0a 09 20 buf (box #t)].. 0370: 20 20 5b 62 79 74 65 73 20 28 6e 6e 2d 72 65 63 [bytes (nn-rec 0380: 76 20 73 6f 63 6b 20 62 75 66 20 4e 4e 5f 4d 53 v sock buf NN_MS 0390: 47 20 30 29 5d 29 0a 20 20 20 20 20 20 28 70 72 G 0)]). (pr 03a0: 69 6e 74 66 20 22 43 4c 49 45 4e 54 20 28 7e 64 intf "CLIENT (~d 03b0: 29 3a 20 52 45 43 45 49 56 45 44 20 7e 64 7e 6e ): RECEIVED ~d~n 03c0: 22 20 6e 61 6d 65 20 28 75 74 66 38 2d 3e 73 74 " name (utf8->st 03d0: 72 69 6e 67 20 28 75 6e 62 6f 78 20 62 75 66 29 ring (unbox buf) 03e0: 29 29 0a 20 20 20 20 20 20 28 6c 6f 6f 70 29 29 )). (loop)) 03f0: 29 0a 20 20 28 6e 6e 2d 73 68 75 74 64 6f 77 6e ). (nn-shutdown 0400: 20 73 6f 63 6b 20 65 69 64 29 29 0a 0a 28 64 65 sock eid))..(de 0410: 66 69 6e 65 20 61 72 67 76 20 28 63 6f 6d 6d 61 fine argv (comma 0420: 6e 64 2d 6c 69 6e 65 2d 61 72 67 75 6d 65 6e 74 nd-line-argument 0430: 73 29 29 0a 28 64 65 66 69 6e 65 20 61 72 67 63 s)).(define argc 0440: 20 28 6c 65 6e 67 74 68 20 61 72 67 76 29 29 0a (length argv)). 0450: 0a 28 63 6f 6e 64 0a 20 5b 28 61 6e 64 20 28 3e .(cond. [(and (> 0460: 20 61 72 67 63 20 31 29 20 28 73 74 72 69 6e 67 argc 1) (string 0470: 3d 3f 20 73 65 72 76 65 72 2d 6e 61 6d 65 20 28 =? server-name ( 0480: 63 61 72 20 61 72 67 76 29 29 29 0a 20 20 28 73 car argv))). (s 0490: 65 72 76 65 72 20 28 63 61 64 72 20 61 72 67 76 erver (cadr argv 04a0: 29 29 5d 0a 20 5b 28 61 6e 64 20 28 3e 20 61 72 ))]. [(and (> ar 04b0: 67 63 20 32 29 20 28 73 74 72 69 6e 67 3d 3f 20 gc 2) (string=? 04c0: 63 6c 69 65 6e 74 2d 6e 61 6d 65 20 28 63 61 72 client-name (car 04d0: 20 61 72 67 76 29 29 29 0a 20 20 28 63 6c 69 65 argv))). (clie 04e0: 6e 74 20 28 63 61 64 72 20 61 72 67 76 29 20 28 nt (cadr argv) ( 04f0: 63 61 64 64 72 20 61 72 67 76 29 29 5d 0a 20 5b caddr argv))]. [ 0500: 65 6c 73 65 0a 20 20 28 70 72 69 6e 74 66 20 22 else. (printf " 0510: 55 73 61 67 65 3a 20 70 75 62 73 75 62 20 7e 64 Usage: pubsub ~d 0520: 7c 7e 64 20 3c 55 52 4c 3e 20 3c 41 52 47 3e 20 |~d <URL> <ARG> 0530: 2e 2e 2e 27 7e 6e 22 20 73 65 72 76 65 72 2d 6e ...'~n" server-n 0540: 61 6d 65 20 63 6c 69 65 6e 74 2d 6e 61 6d 65 29 ame client-name) 0550: 5d 29 0a 0a 0a 23 21 65 6f 66 0a 0a 2e 2f 70 75 ])...#!eof.../pu 0560: 62 73 75 62 20 73 65 72 76 65 72 20 69 70 63 3a bsub server ipc: 0570: 2f 2f 2f 74 6d 70 2f 70 75 62 73 75 62 2e 69 70 ///tmp/pubsub.ip 0580: 63 20 26 20 73 65 72 76 65 72 3d 24 21 20 26 26 c & server=$! && 0590: 20 73 6c 65 65 70 20 31 0a 2e 2f 70 75 62 73 75 sleep 1../pubsu 05a0: 62 20 63 6c 69 65 6e 74 20 69 70 63 3a 2f 2f 2f b client ipc:/// 05b0: 74 6d 70 2f 70 75 62 73 75 62 2e 69 70 63 20 63 tmp/pubsub.ipc c 05c0: 6c 69 65 6e 74 30 20 26 20 63 6c 69 65 6e 74 30 lient0 & client0 05d0: 3d 24 21 0a 2e 2f 70 75 62 73 75 62 20 63 6c 69 =$!../pubsub cli 05e0: 65 6e 74 20 69 70 63 3a 2f 2f 2f 74 6d 70 2f 70 ent ipc:///tmp/p 05f0: 75 62 73 75 62 2e 69 70 63 20 63 6c 69 65 6e 74 ubsub.ipc client 0600: 31 20 26 20 63 6c 69 65 6e 74 31 3d 24 21 0a 2e 1 & client1=$!.. 0610: 2f 70 75 62 73 75 62 20 63 6c 69 65 6e 74 20 69 /pubsub client i 0620: 70 63 3a 2f 2f 2f 74 6d 70 2f 70 75 62 73 75 62 pc:///tmp/pubsub 0630: 2e 69 70 63 20 63 6c 69 65 6e 74 32 20 26 20 63 .ipc client2 & c 0640: 6c 69 65 6e 74 32 3d 24 21 0a 73 6c 65 65 70 20 lient2=$!.sleep 0650: 35 0a 6b 69 6c 6c 20 24 73 65 72 76 65 72 20 24 5.kill $server $ 0660: 63 6c 69 65 6e 74 30 20 24 63 6c 69 65 6e 74 31 client0 $client1 0670: 20 24 63 6c 69 65 6e 74 32 0a $client2.