知识大全 Java Socket多线程服务端、客户端

Posted 2022-07-19 常量

篇首语：怀抱观古今，寝食展戏谑。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 Java Socket多线程服务端、客户端相关的知识，希望对你有一定的参考价值。

Java Socket多线程服务端、客户端 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

　　//主方法package huhai demo socket

　　public class Main

　　/** 功能说明 * @param args * @author 胡海* @throws InterruptedException * @since 下午 */

　　public static void main（String[] args） throws InterruptedException Thread serverTthread = new Thread（new Runnable（） public void run（） new SocketServer（）） serverTthread start（） Thread sleep（） Thread clientThread = new Thread（new Runnable（） public void run（） new SocketClient（）） clientThread start（）

　　//客户端<pre name= code class= java >package huhai demo socket

　　import java io BufferedReader import java io InputStreamReader import java io PrintWriter import Socket

　　public class SocketClient private Socket socket private int port = private String hostIp =

　　public SocketClient（） try String message = null BufferedReader in = null PrintWriter out = null BufferedReader line = null while（！SocketCommand CONST_QUIT equals（message）） socket = new Socket（hostIp port） in = new BufferedReader（new InputStreamReader（socket getInputStream（））） out = new PrintWriter（socket getOutputStream（） true） line = new BufferedReader（new InputStreamReader（System in））

　　System out println（ please input some characters ） message = line readLine（） out println（message） System out println（ Back message from server [ + in readLine（） + ] ） System out println（ Client exit ） line close（） out close（） in close（） socket close（） catch （Exception e） e printStackTrace（）

　　public static void main（String[] args） new SocketClient（）

　　//服务端view plain package huhai demo socket

　　import java io BufferedReader import java io IOException import java io InputStreamReader import java io PrintWriter import ServerSocket import Socket import ncurrent ExecutorService import ncurrent Executors

　　public class SocketServer private ServerSocket serverSocket private Socket socket private int port = private ExecutorService executeService = Executors newFixedThreadPool（）

　　public SocketServer（） try serverSocket = new ServerSocket（port） // serverSocket = new ServerSocket（port InetAddress getByName（）） System out println（ SocketServer have been started [ + serverSocket + ] ） while（true） socket = serverSocket accept（） executeService submit（new Runnable（） public void run（） try BufferedReader in = new BufferedReader（new InputStreamReader（socket getInputStream（））） PrintWriter out = new PrintWriter（socket getOutputStream（） true）

　　String line = in readLine（） System out println（ Server Received [ + line + ] ） out println（ Server Received [ + line + ] ） out close（） in close（） catch （Exception e） e printStackTrace（） finally try socket close（） catch （IOException e） System out println（ close socket error ） e printStackTrace（）） catch （Exception e） e printStackTrace（） finally try if（null ！= serverSocket） serverSocket close（） System out println（ serverSocket close ） catch （Exception e） e printStackTrace（）

　　public static void main（String[] args） new SocketServer（）

　　//常量view plain package huhai demo socket

cha138/Article/program/Java/hx/201311/25705