zeroMQ java入门例子

小灰灰 2021-01-29 17:24 613阅读 0赞

<dependency>
        <groupId>org.zeromq</groupId>
        <artifactId>jeromq</artifactId>
        <version>0.5.2</version>
    </dependency>

服务端：

ZContext context = new ZContext();
            ZMQ.Socket socket = context.createSocket(SocketType.REP);
            String url = "tcp://*:9999";
            try {
                socket.bind(url);//绑定地址
            } catch (ZMQException e) {
                throw e;
            }
            boolean wait = true;
            while (wait) {//服务器一直循环
                try {
                    System.out.println("server...");
                    byte[] request = socket.recv(0);//接收的客户端数据
                    String getData=new String(request);
                    if (getData.equals("roadMessage:")) {
                        socket.send("OK".toString(),1);
                    }else{
                        socket.send("error".toString(),1);
                    }
                } catch (Exception e) {
                    throw e;
                }
            }

客户端：

ZMQ.Context context = ZMQ.context(1);
    ZMQ.Socket socket = context.socket(ZMQ.REQ);
    socket.connect("tcp://localhost:9999");
    String requestString = "roadMessage:";
    socket.send(requestString, 0);
    Thread.sleep(100);
    byte[] reply = socket.recv(0);
    System.out.println("客户端接收的是: [" + new String(reply) + "]");

发表评论取消回复

表情：

评论列表（有 0 条评论，613人围观）

还没有评论，来说两句吧...

相关阅读

相关 ZeroMQ基础入门

mq是消息队列（message queue）的简称，目前有多种消息队列可用，包括RabbitMQ、Kafka等，它们各有特色，可以结合具体的项目需求使用。 ZeroMQ简称Z

小咪咪/ 2022年09月04日 11:42/ 0 赞/ 207 阅读

相关 Exts 入门例子

[http://www.cnblogs.com/madyina/category/269978.html][http_www.cnblogs.com_madyina_categ

待我称王封你为后i/ 2022年08月26日 09:01/ 0 赞/ 274 阅读

相关 ActiveMQ 入门例子

一：新建Maven项目，加入如下依赖 <dependency> <groupId>org.apache.activemq</groupId> <a

向右看齐/ 2022年08月03日 05:26/ 0 赞/ 199 阅读

相关 OSGI入门例子

本例子是基于felix容器运行的例子一：使用eclipse新建一个 Plug-in Project 项目 ![Center][] 注意， 1：Pr

野性酷女/ 2022年08月02日 09:44/ 0 赞/ 234 阅读

相关 ZeroMQ基础

第一章 ZeroMQ基础拯救世界如何解释ZMQ？有些人会先说一堆ZMQ的好：它是一套用于快速构建的套接字组件；它的信箱系统有超强的路由能力；它太快了！而有些人则

青旅半醒/ 2022年07月16日 02:43/ 0 赞/ 239 阅读

相关 Redis入门例子

Redis认识 REmote DIctionary Server(Redis) 是一个由Salvatore Sanfilippo写的key-value存储系统。 Red

墨蓝/ 2022年06月08日 21:46/ 0 赞/ 273 阅读

相关 Spring入门例子

1、新建JavaProject项目springFirst，新建接口类包、实现类包、测试类包 ![70][] 2、编写接口类Human package com.in

ゞ浴缸里的玫瑰/ 2022年05月19日 13:51/ 0 赞/ 303 阅读

相关 myBatis入门例子

1，本文采用的Mybatis框架版本为： mybatis-3.0.4.jar 2，以持久化一个简单的User bean为例 User实体类的代码如下：

淡淡的烟草味﹌/ 2022年01月16日 10:47/ 0 赞/ 317 阅读

相关 spring入门例子

组件扫描 @Component：表示这个类须在应用程序中被创建 @ComponentScan：自动发现应用程序中被创建的类自动装配

雨点打透心脏的1/2处/ 2021年11月05日 20:16/ 0 赞/ 385 阅读

相关 zeroMQ java入门例子

<dependency> <groupId>org.zeromq</groupId> <artifactId>jeromq</artifactId> ...

小灰灰/ 2021年01月29日 17:24/ 0 赞/ 614 阅读