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);
		}
	}
}

服务端示例效果：