Package java.net

Examples of java.net.ServerSocket.accept()


  public static void main(String args[]) {
   
    try
    ServerSocket ss = new ServerSocket( 7042 );
      while(true) { //loop forever
      Socket s = ss.accept(); //Blocks waiting for a new connection
      HTTPServer http_server = new HTTPServer( s );
      http_server.start(); //Start the child process
    }
    }catch(Exception e) {
      e.printStackTrace();
View Full Code Here


      Socket client = null;
      int listenPort = Config.listen_port();
      ServerSocket ss = new ServerSocket(listenPort);
      logger.info("����" + listenPort + "�˿ڣ��ȴ��ͻ��˵�����...");
      while (true) {
        client = ss.accept();
        logger.info("���յ�������" + client.toString());
        SegmentService service = new SegmentService(dictLib, client);
        service.start();
      }
    } catch (IOException e) {
View Full Code Here

            // Enter the main loop
            while (!interrupted) {
                // Get the listener
                Socket s = null;
                try {
                    s = ss.accept();
                } catch (java.io.InterruptedIOException err) {
                    s = null;
                }

                // if we actually got a socket, process it. Otherwise go around
View Full Code Here

            // Enter the main loop
            while (!interrupted) {
                // Get the listener
                Socket s = null;
                try {
                    s = ss.accept();
                } catch (java.io.InterruptedIOException err) {
                    s = null;
                }

                // if we actually got a socket, process it. Otherwise go around
View Full Code Here

                // Check for control request
                Socket accepted = null;
                try {
                    if (controlSocket != null) {
                        accepted = controlSocket.accept();
                        if (accepted != null) {
                            handleControlRequest(accepted);
                        }
                    } else {
                        Thread.sleep(CONTROL_TIMEOUT);
View Full Code Here

      e.printStackTrace();
    }
    while(true) {
      Socket socket = null;
      try {
        socket = ss.accept();
        System.out.println("接入....");
      } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
View Full Code Here

          {
             serverSocket.close();
             throw new IOException("RETR");
          }
          dataSocket = serverSocket.accept();
          serverSocket.close();
    }
    public void stop()
    {
       try
View Full Code Here

          }
          log().info("Endpoint created at port "+_port);
        }
       
        try {
          Socket socket = serverSocket.accept();
          if (_running) {
            _pool.spawn(new ClientConnection(this, socket));
          } else {
            try {
              socket.close();
View Full Code Here

    }

    Socket clientSocket = null;
    try {
      System.err.println("Waiting for client to connect.");
      clientSocket = serverSocket.accept();
      System.err.println("Client is now connected.");
    } catch (IOException e) {
      System.err.println("Accept failed: "+e.getMessage());
      throw new RuntimeException("Failed to connect to the client");
    }
View Full Code Here

      Executors.newSingleThreadExecutor().execute(new Runnable() {
        public void run() {
          try {
            while (true) {
              // Wait client calls
              Socket socket = serverSocket.accept();
              // Read client params
              BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));
              String [] params = reader.readLine().split("\t");
              reader.close();
              socket.close();
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.