本实例实现了服务端通过Socket进行客户端消息的监听,客户端向服务端发送字符串消息。
服务端代码:
package InternetCode.Socket.Exa503;
import java.io.*;
import java.net.*;
/**
* 通过服务器套接字接收客户端发送的信息
*/
public class ServerSocketFrame {
// 声明BufferedReader对象
private BufferedReader reader;
// 声明ServerSocket对象
private ServerSocket server;
// 声明Socket对象socket
private Socket socket;
public void getServer() {
try {
// 实例化Socket对象
server = new ServerSocket(1978);
System.out.println("服务器套接字已经创建成功\n");
while (true) {
// 如果套接字是连接状态
System.out.println("等待客户机的连接......\n");
// 等待连接获得Socket对象
socket = server.accept();
System.out.println("连接成功。\n");
//获得客户端通讯输入流
reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
//监听客户端通信输入流
getClientInfo();
}
} catch (Exception e) {
e.printStackTrace();
}
}
private void getClientInfo() {
try {
while (true) {
System.out.println("接收到客户机发送的信息:" + reader.readLine() + "\n"); // 获得客户端信息
}
} catch (Exception e) {
System.out.println("客户端已退出。\n"); // 输出异常信息
} finally {
try {
if (reader != null) {
reader.close();// 关闭流
}
if (socket != null) {
socket.close(); // 关闭套接字
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) {
ServerSocketFrame frame = new ServerSocketFrame();
frame.getServer();
}
}
客户端代码:
package InternetCode.Socket.Exa503;
import java.io.*;
import java.net.*;
import java.util.Scanner;
/**
* 通过套接字发送和接收信息
*/
public class ClientSocketFrame {
// 声明PrintWriter类对象
private PrintWriter writer;
// 声明Socket对象
private Socket socket;
Scanner scanner;
private void connect() {
System.out.println("尝试连接......\n"); // 文本域中信息信息
try {
// 实例化Socket对象
socket = new Socket("127.0.0.1", 1978);
// 创建输出流对象
writer = new PrintWriter(socket.getOutputStream(), true);
// 文本域中提示信息
System.out.println("完成连接。\n");
while(true){
scanner=new Scanner(System.in);
System.out.println("请输入要发送的消息:");
String text=scanner.nextLine();
if(text.equals("quit")){
break;
}
writer.println(text);
}
} catch (Exception e) {
e.printStackTrace(); // 输出异常信息
}
}
public static void main(String[] args) {
// 主方法
ClientSocketFrame clien = new ClientSocketFrame();
clien.connect();
}
}
首先运行服务器:
然后运行客户端:
成功!!