Java Socket通信之客户端服务端交互聊天案例

服务端接收客户端发送过来的数据，并打印在控制台上。

Tcp传输，客户端建立的过程。

1，创建服务端socket服务。通过ServerSocket对象。

2，服务端必须对外提供一个端口，否则客户端无法连接。

3，获取连接过来的客户端对象。

4，通过客户端对象获取socket流读取客户端发来的数据并打印在控制台上。

服务端代码

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
/**
* Created by yuandl on 2016-10-17.
* 服务端接收客户端发送过来的数据，并打印在控制台上。
*/

public class Server {
static ServerSocket serverSocket = null;

public static void main(String[] args) {
try {
//1创建服务端对象。
serverSocket = new ServerSocket(8868);
//2,获取连接过来的客户端对象。
Socket socket = serverSocket.accept();
System.out.println("来自客户端【" + socket.getInetAddress().getHostAddress() + "】的连接");
BufferedReader bufferedReader = null;
BufferedReader bufferedReader_SystemIN = null;
BufferedWriter bufferedWriter = null;
//3，通过socket对象获取输入流，要读取客户端发来的数据
bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
//4，通过字符输入流获取键盘输入，要读取控制台写给客户端的数据
bufferedReader_SystemIN = new BufferedReader(new InputStreamReader(System.in));
//5.使用客户端socket对象的输出流给客户端返回数据
bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
String message = "";
while ((message = bufferedReader.readLine()) != null) {
System.out.println("来自客户端【" + socket.getInetAddress().getHostAddress() + "】说:" + message);
System.out.print("请输入：");
String s = bufferedReader_SystemIN.readLine();
bufferedWriter.write(s);
bufferedWriter.newLine();
bufferedWriter.flush();
}

} catch (IOException e) {
e.printStackTrace();
} finally {
try {
serverSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

客户端发数据到服务端

Tcp传输，客户端建立的过程。

1，创建tcp客户端socket服务。使用的是Socket对象。建议该对象一创建就明确目的地。要连 接的主机。

2，如果连接建立成功，说明数据传输通道已建立。该通道就是socket流 ,是底层建立好的。 既然是流，说明这里既有输入，又有输出。想要输入或者输出流对象，可以找Socket来获取。可以通过getOutputStream(),和getInputStream()来获取两个字节流。

3，使用输出流，将数据写出。

4，关闭资源。

客户端代码

import java.io.*;
import java.net.Socket;
/**
* Created by yuandl on 2016-10-17.
* 客户端发数据到服务端
*/
public class Client {

public static void main(String[] args) {
Socket socket = null;
BufferedReader bufferedReader = null;
BufferedReader bufferedReader_Server = null;
BufferedWriter bufferedWriter = null;
try {
//1,创建socket客户端对象。
socket = new Socket("127.0.0.1", 8868);
//2，获取键盘录入。获取控制台用户输入的信息
bufferedReader = new BufferedReader(new InputStreamReader(System.in));
//3,socket输入流。读取服务端返回的数据
bufferedReader_Server = new BufferedReader(new InputStreamReader(socket.getInputStream()));
//4,socket输出流。将控制台信息数据输出给服务端
bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));

System.out.print("请输入：");
String message = "";
while ((message = bufferedReader.readLine()) != null) {
bufferedWriter.write(message);
bufferedWriter.newLine();
bufferedWriter.flush();
String getMessage = bufferedReader_Server.readLine();
System.out.println("来自服务器说：" + getMessage);
System.out.print("请输入：");
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}

}
}

运行效果

先运行服务端，再运行客户端