package com.basic.security.utils;

//import nanomsg.reqrep.RepSocket;
//import nanomsg.reqrep.ReqSocket;
//
//public class JnanomsgServer {
//    private static String url = "tcp://0.0.0.0:7789";
//
//    public static void main(String[] args) {
//        receive();
////        send();
//    }
//    public static void receive() {
//        System.out.println("JnanomsgServer.receive");
//        final RepSocket socket = new RepSocket();
//        socket.setRecvTimeout(-1);
//        socket.bind(url);
//        new Thread(new Runnable() {
//            public void run() {
//                while (true) {
//                    try {
//                        System.out.println( "received:" + socket.recvString());  // 阻塞socket，直到超时或者有响应
//                        Thread.sleep(1000);
//                        socket.send("received");
//
//                    } catch (Exception e) {       // 忽略超时
////                        e.printStackTrace();
//                    	System.out.println(e.getMessage());
//                    }
//                }
//            }
//        }).start();
//    }
//
////    private static void send() {
////        final ReqSocket socket = new ReqSocket();
////        socket.connect(url);
////        new Thread(new Runnable() {
////            public void run() {
////                while (true) {
////                    try {
////                        socket.send("hello");
////                        Thread.sleep(1000);
////                        System.out.println( "node0:" + socket.recvString());  // 阻塞socket，直到超时或者有响应
////                    } catch (InterruptedException e) {
////                        e.printStackTrace();
////                    } catch (Exception e) {
////                        // e.printStackTrace();
////                    }
////                }
////            }
////        }).start();
////    }
//}