JAVA - Socket
从开学到现在 也学了三个月时间的java了，一直在 在 语法和基本使用上周旋，井底之娃一枚。 这两天 有学长指点，花了两天的时间 学习了java多线程和socket的简单使用，利用周末时间 自己写了个 Socket 多客户端的 Demo，有很多不成熟或者不好的 地方，请指正。
TCP 的 Java 支持
协议相当于相互通信的程序间达成的一种约定，它规定了分组报文的结构、交换方式、包含的意义以及怎样对报文所包含的信息进行解析，TCP/IP 协议族有 IP 协议、TCP 协议和 UDP 协议。现在 TCP/IP 协议族中的主要 socket 类型为流套接字（使用 TCP 协议）和数据报套接字（使用 UDP 协议）。
Socket套接字 是面向连接的通信，基于TCP/IP协议提供了稳定的支持（Ps: TCP/IP 传输效率低于 UDP），TCP/IP 提供了Socket和Serversocket两个类， 使用 Serversocket 实例来监听端口是否 有客户端请求，并通过 accept（）方法 来返回一个Socket 实例，客户端的socket和服务端的socket 就这样建立了连接，每个socket 有自己的io流 ，那么服务端的输入流对应客户端的输出流，客户端的输出流对应服务端的输入流，在这里输入流 我们采用(BufferedReader)包装流，输入采用(PrintStream)包装流，通过包装流 包装 输入输初流，可以方便程序数据的使用。
典型的 TCP 服务端执行如下两步操作：
创建一个 ServerSocket 实例并指定本地端口，用来监听客户端在该端口发送的 TCP 连接请求；
-
重复执行：
调用 ServerSocket 的 accept（）方法以获取客户端连接，并通过其返回值创建一个 Socket 实例；
- 为返回的 Socket 实例开启新的线程，并使用返回的 Socket 实例的 I/O 流与客户端通信； 通信完成后，使用 Socket 类的 close（）方法关闭该客户端的
套接字连接。
好了话不多说，下面贴程序。
***服务端代码***
package socket多客户端; import java.io.IOException;
import java.net.*;
import java.util.ArrayList;
public class Server { private static ArrayList<Thread_Client> list = new ArrayList<>(); private static final int PORT = 6789;
private static ServerSocket serverSocket;
private static Socket socket; static void send(String string){ // 使用 for 循环 ， 遍历Arraylist 广播某客户端传来的消息
for(Thread_Client thread_Client : list){
// 调用 子线程的 send 方法
thread_Client.send(string);
} } public static void main(String[] args) { System.out.println("服务端开始运行..."); try { serverSocket = new ServerSocket(PORT); while(true){
socket = serverSocket.accept();
Thread_Client thread_Client = new Thread_Client(socket);
thread_Client.start();
System.out.println("已连接！");
list.add(thread_Client); } } catch (Exception e) {
// TODO: handle exception
System.out.println("服务端异常1");
}finally { try {
socket.close();
serverSocket.close(); } catch (IOException e2) {
// TODO: handle exception
System.out.println("服务端异常2");
} } } }
*** 然后是 处理连接后socket 的子线程***
package socket多客户端; import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.lang.*;
import java.net.Socket; public class Thread_Client extends Thread{ private BufferedReader bufferedReader = null;
private PrintStream printStream = null; Socket socket; public Thread_Client(Socket socket) {
//
this.socket = socket;
} @Override
public void run() {
// TODO Auto-generated method stub
super.run(); try {
Get_Set(socket); } catch (Exception e) {
// TODO: handle exception
System.out.println("异常1");
} } public void send(String string){
if(string != null){
printStream.println(string);
printStream.flush();
}
} public void Get_Set(Socket socket){ try {
bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
printStream = new PrintStream(socket.getOutputStream()); Boolean flag = true;
while(flag){
String string = bufferedReader.readLine();
if("".equals(string) || string == null){
flag = false;
}else{
if("end".equals(string)){
flag = false;
}else{
System.out.println("read : " + string);
//调用 主线程 广播
Server.send(string);
}
}
} } catch (IOException e) {
// TODO: handle exception
System.out.println("异常2");
}
} }
*** 最后是 客户端代码 ***
package socket多客户端; import java.io.*;
import java.net.*;
import java.util.Scanner; public class Client { private static Socket socket;
private static BufferedReader bufferedReader;
private static PrintStream printStream; // 将 读服务端数据封装在 Client—read 方法里
public static void Client_read(Socket socket){
// 匿名内部类 开 一个子线程
new Thread(new Runnable() {
private BufferedReader bufferedReader_ec; @Override
public void run() {
// TODO Auto-generated method stub try {
bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
String str = bufferedReader.readLine();
if("".equals(str) || str == null || "end".equals(str)){ }else{
System.out.println(str);
} } catch (Exception e) {
// TODO: handle exception
}
}
}).start();
} // Get_Set 方法 处理 客户端与服务端 数据的读写
static void Get_Set(Socket socket){ try {
bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
printStream = new PrintStream(socket.getOutputStream());
Scanner keyboard = new Scanner(System.in); Boolean flag = true;
while(flag){ // 在这里调用 之前封装的 Client_read 方法
Client_read(socket); // 从 键盘 输入数据
String shuru = keyboard.nextLine();
if("".equals(shuru) || shuru == null){
flag = false; // 通过 嵌套if else 筛掉无用值
}else{
if("end".equals(shuru)){
flag = false;
}else{
printStream.println(shuru); // 发送至服务端
printStream.flush();
}
} } } catch (Exception e) {
// TODO: handle exception
} } public static void main(String[] args) { try { socket = new Socket("localhost",6789);
System.out.println("客户端已连接至服务端!");
Get_Set(socket); } catch (Exception e) {
// TODO: handle exception
System.out.println("客户端异常1");
}finally {
try {
printStream.close();
bufferedReader.close();
socket.close(); } catch (Exception e2) {
// TODO: handle exception
System.out.println("客户端异常2");
}
} } }
好了 ，下面我们来运行 看看结结果。
第一个控制台是 服务端
第二个控制台是 客户端1
第三个控制台是 客户端2
这样我们就实现了 一个简单的基于TCP/IP协议的socket多客户端通信。
笔者 还是个 编程菜鸟，有什么不好的地方，希望各位大牛可以指正。