zmqpub.m 338 B

123456789101112131415161718192021222324
  1. function zmqpub(msg,varargin)
  2. import org.zeromq.ZMQ
  3. %%
  4. context = ZMQ.context(1);
  5. sub = context.socket(ZMQ.SUB);
  6. sub.connect('tcp://localhost:6001');
  7. sub.subscribe(uint8('416'));
  8. while 1
  9. try
  10. msg = sub.recvStr(ZMQ.NOWAIT);
  11. char(msg');
  12. catch
  13. fprintf(2,'no msg\n')
  14. pause(0.1);
  15. end
  16. end
  17. end