相关资料地址

ZeroMQ | Java

1. Basics | ØMQ - The Guide

GitHub - zeromq/jeromq: Pure Java ZeroMQ

引入依赖

参考上边的githun连接

项目使用

private static final Logger logger = LoggerFactory.getLogger(ZeroClient.class);

    @Value("${spring.zeromq.enable}")
    private Boolean enabled;

    public ZMQ.Socket socket;

    @PostConstruct
    public void init() {
        if (enabled) {
            connect();
        }
    }

    private void connect() {
        ZContext context = new ZContext();
        // Socket to talk to client
        socket = context.createSocket(SocketType.PUB);
        String localAddress = null;
        try {
            InetAddress localHost = InetAddress.getLocalHost();
            localAddress = localHost.getHostAddress();
        } catch (UnknownHostException e) {
            logger.warn("获取主机IP失败");
        }
        String uri = "tcp://" + localAddress + ":5555";

        socket.bind(uri);
        logger.info("zeromq connect to " + uri + " success");

    }

项目启动的时候初始化该配置文件，其他地方直接使用该socket即可