Java之socket编程，

Java之socket编程，

1，什么是Socket

网络上的两个程序通过一个双向的通讯连接实现数据的交换，这个双向链路的一端称为一个Socket。Socket通常用来实现客户方和服务方的连接。Socket是TCP/IP协议的一个十分流行的编程界面，一个Socket由一个IP地址和一个端口号唯一确定。可以认为在scoket实现了应用层下的复杂的通信，并对上层透明。

但是，Socket所支持的协议种类也不光TCP/IP一种，因此两者之间是没有必然联系的。在Java环境下，Socket编程主要是指基于TCP/IP协议的网络编程。

       首先我们写一个client

package com.socket.test;

import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket;

public class TalkServer {

public static void main(String[] args) { ServerSocket server = null; try { // 创建一个ServerSocket在端口4700监听客户请求 server = new ServerSocket(TalkClient.port); } catch (Exception e) { System.out.println("can not listen to:" + e); } Socket socket = null; try { // server.accept()阻塞等他客户端请求 ，返回一个socket socket = server.accept();

} catch (Exception e) { System.out.println("failed" + e); }

String result = ""; try { // 从sokcet中获取一个输入流 BufferedReader rb = new BufferedReader(new InputStreamReader(socket.getInputStream())); // 从sokcet中获取一个输出流 PrintWriter os = new PrintWriter(socket.getOutputStream()); // 在标准输出上打印从客户端读入的字符串 result = rb.readLine(); while (!result.equals("stop")) {

os.println(result);

os.flush();

System.out.println("server " + result);

result = rb.readLine();

} os.close(); // 关闭Socket输出流

rb.close(); // 关闭Socket输入流

socket.close(); // 关闭Socket

server.close(); // 关闭ServerSocket } catch (Exception e) { e.printStackTrace(); } } }
接着我们写一个sever  package com.socket.test;


import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;


public class TalkServer {


public static void main(String[] args) {
ServerSocket server = null;
try {
// 创建一个ServerSocket在端口4700监听客户请求
server = new ServerSocket(TalkClient.port);
} catch (Exception e) {
System.out.println("can not listen to:" + e);
}
Socket socket = null;
try {
// server.accept()阻塞等他客户端请求 ，返回一个socket
socket = server.accept();


} catch (Exception e) {
System.out.println("failed" + e);
}


String result = "";
try {
// 从sokcet中获取一个输入流
BufferedReader rb = new BufferedReader(new InputStreamReader(socket.getInputStream()));
// 从sokcet中获取一个输出流
PrintWriter os = new PrintWriter(socket.getOutputStream());
// 在标准输出上打印从客户端读入的字符串
result = rb.readLine();
while (!result.equals("stop")) {


os.println(result);


os.flush();


System.out.println("server " + result);


result = rb.readLine();


}
os.close(); // 关闭Socket输出流


rb.close(); // 关闭Socket输入流


socket.close(); // 关闭Socket


server.close(); // 关闭ServerSocket
} catch (Exception e) {
e.printStackTrace();
}
}
}

以上仅仅是一个客户端对应一个服务端，如果需要一个服务端对多个客户端可以使用线程池