Socket一对多
2013-11-24 15:48
134 查看
public static void main(String[] args) throws IOException {
ServerSocket server = new ServerSocket(10000);
while (true) {
Socket socket = server.accept();
initSocket(socket);
}
}
private static void initSocket(final Socket client) throws IOException {
new Thread(new Runnable() {
public void run() {
BufferedReader in = null;
PrintWriter out = null;
try {
in = new BufferedReader(new InputStreamReader(client.getInputStream()));
out = new PrintWriter(client.getOutputStream());
String msg = in.readLine();
System.out.println(msg);
out.println("Server received " + msg);
out.flush();
} catch(IOException ex) {
ex.printStackTrace();
} finally {
try {
in.close();
} catch (Exception e) {}
try {
out.close();
} catch (Exception e) {}
try {
client.close();
} catch (Exception e) {}
}
}
}).start();
}
public static void main(String[] args) throws Exception {
Socket socket = new Socket("localhost", 10000);
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream());
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
String msg = reader.readLine();
out.println(msg);
out.flush();
System.out.println(in.readLine());
socket.close();
}
ServerSocket server = new ServerSocket(10000);
while (true) {
Socket socket = server.accept();
initSocket(socket);
}
}
private static void initSocket(final Socket client) throws IOException {
new Thread(new Runnable() {
public void run() {
BufferedReader in = null;
PrintWriter out = null;
try {
in = new BufferedReader(new InputStreamReader(client.getInputStream()));
out = new PrintWriter(client.getOutputStream());
String msg = in.readLine();
System.out.println(msg);
out.println("Server received " + msg);
out.flush();
} catch(IOException ex) {
ex.printStackTrace();
} finally {
try {
in.close();
} catch (Exception e) {}
try {
out.close();
} catch (Exception e) {}
try {
client.close();
} catch (Exception e) {}
}
}
}).start();
}
public static void main(String[] args) throws Exception {
Socket socket = new Socket("localhost", 10000);
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream());
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
String msg = reader.readLine();
out.println(msg);
out.flush();
System.out.println(in.readLine());
socket.close();
}
相关文章推荐
- .Net和Java的socket机制比较
- Perl Socket example
- nginx、php-fpm默认配置与性能–TCP socket还是unix domain socket
- windows网络编程socket-IO 5种设计模型
- socket实例
- linux socket编程示例——UDP
- Socket, WebSocket
- chrome driver 打开出错: socket.error: [Errno 10054]
- python socket 数据传输小记
- 在J2ME中使用Socket通过cmwap接入点访问安全HTTPS
- 一个 Linux Windows下都可运行的 Socket 程序
- java网络编程--socket服务端客户端(1:1)
- SuperSocket服务器架设(一):认识SuperSocket
- http、socket的区别
- iOS开发日记11-http和socket
- 局域网内主机之间Socket通信实现
- ServerSocket和ServerSocketChannel实例
- 基于Socket简单的客户端-服务端例子
- Socket 编程时候遇到的Broken pipe问题
- Socket 编程,一个服务器,多个客户端,互相通信(分享)