网络通讯的三要素
ip地址：计算机在网络中的唯一标识
端口：应用程序在计算机中唯一标识
协议：通信协议，常见有UDP和TCP协议
IP地址：
查看本机地址【ipconfig】
端口号：
用于标识计算机上某个特定的网络程序，以整数形式，范围0-65535。也就是1024*64。
其中前0~1024一般已经被系统占用，示例：【127.0.0.1:8080】
协议：
UDP协议
用户数据报协议(User Datagram Protocol)
UDP是无连接通信协议，即在数据传输时，数据的发送端和接收端不建立逻辑连接
UDP协议消耗系统资源小，通信效率高，所以通常都会用于音频、视频和普通数据的传输
TCP协议
传输控制协议 (Transmission Control Protocol)
TCP协议是面向连接的通信协议，即传输数据之前，在发送端和接收端建立逻辑连接，然后再传输数据，它提供了两台计算机之间可靠无差错的数据传输。
Socket
// 参数一：服务端地址 参数二：服务端端口
Socket socket = new Socket("127.0.0.1", 9527);
1、基础示例
服务端：这里我没有写循环
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; //服务端 public class Server { public static void main(String[] args) throws IOException { System.out.println("========服务端启动============"); // 1.创建接收管道，注册端口 ServerSocket serverSocket = new ServerSocket(9527);// 参数一：定义服务端口 // 2.等待管道连接 Socket accept = serverSocket.accept(); // 3.从管道中获取一个字节输入流 InputStream is = accept.getInputStream(); // 4.字节流升级生缓冲输入流 BufferedReader br = new BufferedReader(new InputStreamReader(is)); // 5.按照行读取消息会更好 System.out.println(accept.getRemoteSocketAddress() + "客户端说了：" + br.readLine()); } }
客户端：
import java.io.IOException; import java.io.OutputStream; import java.io.PrintStream; import java.net.Socket; //发送端 public class Client { public static void main(String[] args) throws IOException { System.out.println("==============客户端启动==============="); // 1.创建发送通信管道 Socket socket = new Socket("127.0.0.1", 9527);// 参数一：服务端地址 参数二：服务端端口 // 2.从scoket管道中获得一个字节输出流,负责发送数据 OutputStream os = socket.getOutputStream(); // 3.字节流升级成打印流 PrintStream ps = new PrintStream(os); // 4.发送消息 ps.println("我是Client客户端发送给服务端的数据"); ps.flush();// 刷新 } }
先启动服务端，然后再启动客户端，
启动客户端
服务端接收到了客户端的信息。
2、循环监听示例
服务器接收多服务器连续信息，Server代码：
package Demo2; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; //服务端 public class Server { public static void main(String[] args) throws IOException { System.out.println("========服务端启动============"); // 1.创建接收管道，注册端口 ServerSocket serverSocket = new ServerSocket(9527);// 参数一：定义服务端口 while (true) { // 2.等待管道连接 Socket accept = serverSocket.accept(); // 3.从管道中获取一个字节输入流 InputStream is = accept.getInputStream(); // 4.字节流升级生缓冲输入流 BufferedReader br = new BufferedReader(new InputStreamReader(is)); // 5.按照行读取消息会更好 System.out.println(accept.getRemoteSocketAddress() + "客户端说了：" + br.readLine()); } } }
Client1代码
package Demo2; import java.io.IOException; import java.io.OutputStream; import java.io.PrintStream; import java.net.Socket; import java.util.Scanner; //发送端 public class Client1 { public static void main(String[] args) throws IOException { System.out.println("==============客户端启动==============="); Scanner sc = new Scanner(System.in); // 1.创建发送通信管道 // 参数一：服务端地址 参数二：服务端端口 while (true) { Socket socket = new Socket("127.0.0.1", 9527); // 2.从scoket管道中获得一个字节输出流,负责发送数据 OutputStream os = socket.getOutputStream(); // 3.字节流升级成打印流 PrintStream ps = new PrintStream(os); // 4.发送消息 String strInfo = sc.next(); ps.println("Client："+strInfo); ps.flush();// 刷新 } } }
Client2代码：
package Demo2; import java.io.IOException; import java.io.OutputStream; import java.io.PrintStream; import java.net.Socket; import java.util.Scanner; //发送端 public class Client2 { public static void main(String[] args) throws IOException { System.out.println("==============客户端启动==============="); Scanner sc = new Scanner(System.in); // 1.创建发送通信管道 // 参数一：服务端地址 参数二：服务端端口 while (true) { Socket socket = new Socket("127.0.0.1", 9527); // 2.从scoket管道中获得一个字节输出流,负责发送数据 OutputStream os = socket.getOutputStream(); // 3.字节流升级成打印流 PrintStream ps = new PrintStream(os); // 4.发送消息 String strInfo = sc.next(); ps.println("Client2："+strInfo); ps.flush();// 刷新 } } }
这里Client其实可以有很多很多个，都能访问到对应是主服务器。
示例效果：
切换客户端进行输入：
3、双向互动示例
服务端：
import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.net.ServerSocket; import java.net.Socket; //服务端 public class Server { public static void main(String[] args) throws IOException { System.out.println("========服务端启动============"); // 1.创建接收管道，注册端口 ServerSocket serverSocket = new ServerSocket(9527);// 参数一：定义服务端口 BufferedWriter writer = null; while (true) { // 2.等待管道连接 Socket accept = serverSocket.accept(); writer = new BufferedWriter( new OutputStreamWriter(accept.getOutputStream()) ); // 3.从管道中获取一个字节输入流 InputStream is = accept.getInputStream(); // 4.字节流升级生缓冲输入流 BufferedReader br = new BufferedReader(new InputStreamReader(is)); // 5.按照行读取消息会更好 String readLine = br.readLine(); System.out.println(accept.getRemoteSocketAddress() + "客户端说了：" + readLine); writer.write("服务器已收到: " + accept.getRemoteSocketAddress() +"消息"+ readLine +"\n"); //防止消息遗留到本地缓冲区，保证马上发送出去 writer.flush(); } } }
Client端：
package Demo2; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.PrintStream; import java.net.Socket; import java.util.Scanner; //发送端 public class Client1 { public static void main(String[] args) throws IOException { System.out.println("==============客户端启动==============="); Scanner sc = new Scanner(System.in); // 1.创建发送通信管道 // 参数一：服务端地址 参数二：服务端端口 while (true) { Socket socket = new Socket("127.0.0.1", 9527); // 2.从scoket管道中获得一个字节输出流,负责发送数据 OutputStream os = socket.getOutputStream(); // 3.字节流升级成打印流 PrintStream ps = new PrintStream(os); // 4.发送消息 String strInfo = sc.next(); ps.println("Client：" + strInfo); ps.flush();// 刷新 // 3.从管道中获取一个字节输入流 InputStream is = socket.getInputStream(); // 4.字节流升级生缓冲输入流 BufferedReader br = new BufferedReader(new InputStreamReader(is)); // 5.按照行读取消息会更好 String readLine = br.readLine(); System.out.println(socket.getRemoteSocketAddress() + "服务端说了：" + readLine); } } }
服务端示例效果：
切换到客户端：
双向互动效果完毕。
