Shulou(Shulou.com)06/02 Report--

This article introduces the knowledge of "what is the key code of Java Socket programming". In the operation of actual cases, many people will encounter such a dilemma, so let the editor lead you to learn how to deal with these situations. I hope you can read it carefully and be able to achieve something!

Package sterning

Import java.io.BufferedReader

Import java.io.IOException

Import java.io.InputStream

Import java.io.InputStreamReader

Import java.io.OutputStream

Import java.io.PrintWriter

Import java.net.*

Import java.util.concurrent.*

Public class MultiThreadServer {

Private int port=8821

Private ServerSocket serverSocket

Private ExecutorService executorService;// thread pool

Private final int POOL_SIZE=10;// single CPU thread pool size

Public MultiThreadServer () throws IOException {

ServerSocket=new ServerSocket (port)

The availableProcessor () method of / / Runtime returns the number of CPU of the current system.

ExecutorService=Executors.newFixedThreadPool

(Runtime.getRuntime () .availableProcessors () * POOL_SIZE)

System.out.println ("server startup")

}

Public void service () {

While (true) {

Socket socket=null

Try {

/ / receive a customer connection, which will trigger accept () as long as the customer has made a connection; thus establishing a connection

Socket=serverSocket.accept ()

ExecutorService.execute (new Handler (socket))

} catch (Exception e) {

E.printStackTrace ()

}

}

}

Public static void main (String [] args) throws IOException {

New MultiThreadServer () .service ()

}

}

Class Handler implements Runnable {

Private Socket socket

Public Handler (Socket socket) {

This.socket=socket

}

Private PrintWriter getWriter (Socket socket) throws

IOException {

OutputStream socketsocketOut=socket.getOutputStream ()

Return new PrintWriter (socketOut,true)

}

Private BufferedReader getReader (Socket socket) throws

IOException {

InputStream socketsocketIn=socket.getInputStream ()

Return new BufferedReader (new InputStreamReader

(socketIn))

}

Public String echo (String msg) {

Return "echo:" + msg

}

Public void run () {

Try {

System.out.println ("New connection accepted" +

Socket.getInetAddress () + ":" + socket.getPort ()

BufferedReader br=getReader (socket)

PrintWriter pw=getWriter (socket)

String msg=null

While ((msg=br.readLine ())! = null) {

System.out.println (msg)

Pw.println (echo (msg))

If (msg.equals ("bye"))

Break

}

} catch (IOException e) {

E.printStackTrace ()

} finally {

Try {

If (socketbooks null)

Socket.close ()

} catch (IOException e) {

E.printStackTrace ()

}

}

}

}

This is the end of the content of "what is the key code for Java Socket programming". Thank you for reading. If you want to know more about the industry, you can follow the website, the editor will output more high-quality practical articles for you!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.