org.jgroups.util.Util.createServerSocket()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(10.8k)|赞(0)|评价(0)|浏览(191)

本文整理了Java中org.jgroups.util.Util.createServerSocket()方法的一些代码示例，展示了Util.createServerSocket()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Util.createServerSocket()方法的具体详情如下：
包路径：org.jgroups.util.Util
类名称：Util
方法名：createServerSocket

Util.createServerSocket介绍

[英]Finds first available port starting at start_port and returns server socket
[中]查找从start_端口开始的第一个可用端口，并返回服务器套接字

代码示例

代码示例来源：origin: wildfly/wildfly

  1. public void init(String local_addr, String remote_addr, int local_port, int remote_port) throws Exception {
  2.   local=new InetSocketAddress(local_addr, local_port);
  3.   remote=new InetSocketAddress(remote_addr, remote_port);
  4.   srv_sock=Util.createServerSocket(new DefaultSocketFactory(), "server", local.getAddress(), local.getPort(), local.getPort());
  5.   System.out.println("Listening on " + srv_sock.getLocalSocketAddress());
  6.   acceptor=new Acceptor();
  7.   acceptor.start();
  8.   sock=new Socket();
  9.   //sock.bind(local);
  10.   sock.setSendBufferSize(SOCK_SEND_BUF_SIZE);
  11.   sock.setReceiveBufferSize(SOCK_RECV_BUF_SIZE);
  12.   try {
  13.     sock.connect(remote);
  14.     output=new DataOutputStream(new BufferedOutputStream(sock.getOutputStream()));
  15.     System.out.println("Connected to " + sock.getRemoteSocketAddress());
  16.   }
  17.   catch(Throwable t) {
  18.     System.out.println("Failed connecting to " + remote + ": will only act as server");
  19.   }
  20. }

代码示例来源：origin: wildfly/wildfly

  1. public void init(String local_addr, String remote_addr, int local_port, int remote_port) throws Exception {
  2.   local=new InetSocketAddress(local_addr, local_port);
  3.   remote=new InetSocketAddress(remote_addr, remote_port);
  4.   destination=new IpAddress(remote.getAddress(), remote.getPort());
  5.   srv_sock=Util.createServerSocket(new DefaultSocketFactory(), "server", local.getAddress(), local.getPort());
  6.   System.out.println("Listening on " + srv_sock.getLocalSocketAddress());
  7.   acceptor=new Acceptor();
  8.   acceptor.start();
  9.   sock=new Socket();
  10.   //sock.bind(local);
  11.   sock.setSendBufferSize(SOCK_SEND_BUF_SIZE);
  12.   sock.setReceiveBufferSize(SOCK_RECV_BUF_SIZE);
  13.   try {
  14.     sock.connect(remote);
  15.     output=new DataOutputStream(new BufferedOutputStream(sock.getOutputStream()));
  16.     System.out.println("Connected to " + sock.getRemoteSocketAddress());
  17.   }
  18.   catch(Throwable t) {
  19.     System.out.println("Failed connecting to " + remote + ": will only act as server");
  20.   }
  21. }

代码示例来源：origin: wildfly/wildfly

  1. public void init() throws Exception {
  2.   super.init();
  3.   srv_sock=Util.createServerSocket(new DefaultSocketFactory(), "srv-sock", bind_addr, bind_port, bind_port+50);
  4.   acceptor=new Acceptor(bind_addr, bind_port);
  5. }

代码示例来源：origin: wildfly/wildfly

  1. protected void startServerSocket() throws Exception {
  2.   srv_sock=Util.createServerSocket(getSocketFactory(),
  3.                    "jgroups.fd_sock.srv_sock", bind_addr, start_port, start_port+port_range); // grab a random unused port above 10000
  4.   srv_sock_addr=new IpAddress(external_addr != null? external_addr : bind_addr, external_port > 0? external_port : srv_sock.getLocalPort());
  5.   if(local_addr != null)
  6.     cache.add(local_addr, srv_sock_addr);
  7.   if(srv_sock_handler != null)
  8.     srv_sock_handler.start(); // won't start if already running
  9. }

代码示例来源：origin: wildfly/wildfly

  1. protected StateProviderAcceptor createAcceptor() {
  2.   StateProviderAcceptor retval=new StateProviderAcceptor(thread_pool,
  3.                               Util.createServerSocket(getSocketFactory(),
  4.                                           "jgroups.streaming_state_transfer.srv_sock",
  5.                                           bind_addr, bind_port));
  6.   Thread t=getThreadFactory().newThread(retval, "STATE server socket acceptor");
  7.   t.start();
  8.   return retval;
  9. }

代码示例来源：origin: wildfly/wildfly

  1. public void start() throws Exception {
  2.   super.start();
  3.   srv_sock=Util.createServerSocket(getSocketFactory(), "jgroups.stomp.srv_sock", bind_addr, port, port+50);
  4.   if(log.isDebugEnabled())
  5.     log.debug("server socket listening on " + srv_sock.getLocalSocketAddress());
  6.   if(acceptor == null) {
  7.     acceptor=getThreadFactory().newThread(this, "STOMP acceptor");
  8.     acceptor.setDaemon(true);
  9.     acceptor.start();
  10.   }
  11.   endpoint=endpoint_addr != null? endpoint_addr : getAddress();
  12. }

代码示例来源：origin: wildfly/wildfly

  1. /**
  2.  * Creates an instance of {@link TcpServer} that creates a server socket and listens for connections
  3.  * Needs to be started next.
  4.  * @param thread_factory The thread factory used to create new threads
  5.  * @param socket_factory The socket factory used to create sockets
  6.  * @param bind_addr The local address to bind to. If null, the address will be picked by the OS
  7.  * @param srv_port The local port to bind to. If 0, the port will be picked by the OS.
  8.  * @param end_port If srv_port is taken, the next port is tried, until end_port has been reached, in which case an
  9.  *                 exception will be thrown. If srv_port == end_port, only 1 port will be tried.
  10.  * @param external_addr The external address in case of NAT. Ignored if null.
  11.  * @param external_port The external port on the NA. If 0, srv_port is used.
  12.  * @throws Exception Thrown if the creation failed
  13.  */
  14. public TcpServer(ThreadFactory thread_factory, SocketFactory socket_factory,
  15.          InetAddress bind_addr, int srv_port, int end_port,
  16.          InetAddress external_addr, int external_port) throws Exception {
  17.   this(thread_factory, socket_factory);
  18.   // this.srv_sock=this.socket_factory.createServerSocket("jgroups.tcp.server");
  19.   // this.srv_sock.setReuseAddress(reuse_addr);
  20.   // Util.bind(this.srv_sock, bind_addr, srv_port, end_port);
  21.   this.srv_sock=Util.createServerSocket(this.socket_factory, "jgroups.tcp.server", bind_addr, srv_port, end_port);
  22.   acceptor=factory.newThread(new Acceptor(),"TcpServer.Acceptor[" + srv_sock.getLocalPort() + "]");
  23.   local_addr=localAddress(bind_addr, srv_sock.getLocalPort(), external_addr, external_port);
  24.   addConnectionListener(this);
  25. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. public void init(String local_addr, String remote_addr, int local_port, int remote_port) throws Exception {
  2.   local=new InetSocketAddress(local_addr, local_port);
  3.   remote=new InetSocketAddress(remote_addr, remote_port);
  4.   srv_sock=Util.createServerSocket(new DefaultSocketFactory(), "server", local.getAddress(), local.getPort(), local.getPort());
  5.   System.out.println("Listening on " + srv_sock.getLocalSocketAddress());
  6.   acceptor=new Acceptor();
  7.   acceptor.start();
  8.   sock=new Socket();
  9.   //sock.bind(local);
  10.   sock.setSendBufferSize(SOCK_SEND_BUF_SIZE);
  11.   sock.setReceiveBufferSize(SOCK_RECV_BUF_SIZE);
  12.   try {
  13.     sock.connect(remote);
  14.     output=new DataOutputStream(new BufferedOutputStream(sock.getOutputStream()));
  15.     System.out.println("Connected to " + sock.getRemoteSocketAddress());
  16.   }
  17.   catch(Throwable t) {
  18.     System.out.println("Failed connecting to " + remote + ": will only act as server");
  19.   }
  20. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. public void init(String local_addr, String remote_addr, int local_port, int remote_port) throws Exception {
  2.   local=new InetSocketAddress(local_addr, local_port);
  3.   remote=new InetSocketAddress(remote_addr, remote_port);
  4.   destination=new IpAddress(remote.getAddress(), remote.getPort());
  5.   srv_sock=Util.createServerSocket(new DefaultSocketFactory(), "server", local.getAddress(), local.getPort());
  6.   System.out.println("Listening on " + srv_sock.getLocalSocketAddress());
  7.   acceptor=new Acceptor();
  8.   acceptor.start();
  9.   sock=new Socket();
  10.   //sock.bind(local);
  11.   sock.setSendBufferSize(SOCK_SEND_BUF_SIZE);
  12.   sock.setReceiveBufferSize(SOCK_RECV_BUF_SIZE);
  13.   try {
  14.     sock.connect(remote);
  15.     output=new DataOutputStream(new BufferedOutputStream(sock.getOutputStream()));
  16.     System.out.println("Connected to " + sock.getRemoteSocketAddress());
  17.   }
  18.   catch(Throwable t) {
  19.     System.out.println("Failed connecting to " + remote + ": will only act as server");
  20.   }
  21. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. public void init() throws Exception {
  2.   super.init();
  3.   srv_sock=Util.createServerSocket(new DefaultSocketFactory(), "srv-sock", bind_addr, bind_port, bind_port+50);
  4.   acceptor=new Acceptor(bind_addr, bind_port);
  5. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. protected void startServerSocket() throws Exception {
  2.   srv_sock=Util.createServerSocket(getSocketFactory(),
  3.                    "jgroups.fd_sock.srv_sock", bind_addr, start_port, start_port+port_range); // grab a random unused port above 10000
  4.   srv_sock_addr=new IpAddress(external_addr != null? external_addr : bind_addr, external_port > 0? external_port : srv_sock.getLocalPort());
  5.   if(local_addr != null)
  6.     cache.add(local_addr, srv_sock_addr);
  7.   if(srv_sock_handler != null)
  8.     srv_sock_handler.start(); // won't start if already running
  9. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. protected StateProviderAcceptor createAcceptor() {
  2.   StateProviderAcceptor retval=new StateProviderAcceptor(thread_pool,
  3.                               Util.createServerSocket(getSocketFactory(),
  4.                                           "jgroups.streaming_state_transfer.srv_sock",
  5.                                           bind_addr, bind_port));
  6.   Thread t=getThreadFactory().newThread(retval, "STATE server socket acceptor");
  7.   t.start();
  8.   return retval;
  9. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. public void start() throws Exception {
  2.   super.start();
  3.   srv_sock=Util.createServerSocket(getSocketFactory(), "jgroups.stomp.srv_sock", bind_addr, port, port+50);
  4.   if(log.isDebugEnabled())
  5.     log.debug("server socket listening on " + srv_sock.getLocalSocketAddress());
  6.   if(acceptor == null) {
  7.     acceptor=getThreadFactory().newThread(this, "STOMP acceptor");
  8.     acceptor.setDaemon(true);
  9.     acceptor.start();
  10.   }
  11.   endpoint=endpoint_addr != null? endpoint_addr : getAddress();
  12. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. /**
  2.  * Creates an instance of {@link TcpServer} that creates a server socket and listens for connections
  3.  * Needs to be started next.
  4.  * @param thread_factory The thread factory used to create new threads
  5.  * @param socket_factory The socket factory used to create sockets
  6.  * @param bind_addr The local address to bind to. If null, the address will be picked by the OS
  7.  * @param srv_port The local port to bind to. If 0, the port will be picked by the OS.
  8.  * @param end_port If srv_port is taken, the next port is tried, until end_port has been reached, in which case an
  9.  *                 exception will be thrown. If srv_port == end_port, only 1 port will be tried.
  10.  * @param external_addr The external address in case of NAT. Ignored if null.
  11.  * @param external_port The external port on the NA. If 0, srv_port is used.
  12.  * @throws Exception Thrown if the creation failed
  13.  */
  14. public TcpServer(ThreadFactory thread_factory, SocketFactory socket_factory,
  15.          InetAddress bind_addr, int srv_port, int end_port,
  16.          InetAddress external_addr, int external_port) throws Exception {
  17.   this(thread_factory, socket_factory);
  18.   // this.srv_sock=this.socket_factory.createServerSocket("jgroups.tcp.server");
  19.   // this.srv_sock.setReuseAddress(reuse_addr);
  20.   // Util.bind(this.srv_sock, bind_addr, srv_port, end_port);
  21.   this.srv_sock=Util.createServerSocket(this.socket_factory, "jgroups.tcp.server", bind_addr, srv_port, end_port);
  22.   acceptor=factory.newThread(new Acceptor(),"TcpServer.Acceptor[" + srv_sock.getLocalPort() + "]");
  23.   local_addr=localAddress(bind_addr, srv_sock.getLocalPort(), external_addr, external_port);
  24.   addConnectionListener(this);
  25. }

代码示例来源：origin: org.jgroups/com.springsource.org.jgroups

  1. ServerSocket serverSocket = Util.createServerSocket(bind_addr, bind_port);
  2. spawner = new StateProviderThreadSpawner(setupThreadPool(), serverSocket);
  3. new Thread(Util.getGlobalThreadGroup(), spawner, "StateProviderThreadSpawner").start();

代码示例来源：origin: org.jgroups/com.springsource.org.jgroups

  1. Object ret=down_prot.down(evt);
  2. group_name=(String)evt.getArg();
  3. srv_sock=Util.createServerSocket(bind_addr, start_port); // grab a random unused port above 10000
  4. srv_sock_addr=new IpAddress(bind_addr, srv_sock.getLocalPort());
  5. startServerSocket();

内容来源于网络，如有侵权，请联系作者删除！

Util

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Util类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com