Java Socket多线程服务端、客户端
2011-11-08 22:49
337 查看
//主方法 package com.huhai.demo.socket; public class Main { /** 功能说明: * @param args * @author 胡海 * @throws InterruptedException * @since 2011-11-8 下午05:08:05 */ public static void main(String[] args) throws InterruptedException { Thread serverTthread = new Thread(new Runnable(){ public void run(){ new SocketServer(); } }); serverTthread.start(); Thread.sleep(1000); Thread clientThread = new Thread(new Runnable(){ public void run(){ new SocketClient(); } }); clientThread.start(); } } //客户端 package com.huhai.demo.socket; import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; public class SocketClient { private Socket socket; private int port = 10000; private String hostIp = "127.0.0.1"; 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(); } }
//服务端
package com.huhai.demo.socket; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class SocketServer { private ServerSocket serverSocket; private Socket socket; private int port = 10000; private ExecutorService executeService = Executors.newFixedThreadPool(10); public SocketServer(){ try { serverSocket = new ServerSocket(port); // serverSocket = new ServerSocket(port, 10, InetAddress.getByName("192.168.1.102")); 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(); } }
//常量
package com.huhai.demo.socket; public class SocketCommand { public static final String CONST_QUIT = "quit"; }
运行结果:
相关文章推荐
- Java IO——Socket:通过多线程实现多客户端与一个服务端通信
- Java IO——Socket:通过多线程实现多客户端与一个服务端通信
- Java Socket多线程服务端、客户端
- socket ( java ) 简单多个客户端、服务端通信(多线程)
- java socket 多线程的服务端与客户端的demo
- socket ( java ) 简单多个客户端、服务端通信(多线程)
- 在Java中使用Socket模拟客户端和服务端(多线程)
- Socket通讯(objetive-c)客户端与(JAVA)服务端的特殊点
- java socket 多线程通讯 使用mina作为服务端
- Java回炉重造(一)Socket的客户端和服务端通信
- Java网络编程实例---------------------------------基本HTTP客户端及服务端多线程
- java_多线程_socket通信_多个客户端发送,服务器响应
- JAVA 中多线程服务端 多个客户端的实现
- Java中利用socket实现简单的服务端与客户端的通信(入门级)
- java socket 实现服务端与客户端------一对多的服务端和客户机
- android客户端和java服务端之间用socket来传输图片
- Java做Socket服务端与Delphi做Socket客户端的通信
- socket ( java ) 简单客户端、服务端通信
- 【java基础:net】基于多线程的TCP图片上传客户端与服务端Demonstration
- 如何创建基于socket多线程的客户端和服务端