package com;

import java.io.*;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.UnknownHostException;

public class SocketDemo {
 public static void main(String[] args) {
 // 测试Socket连接方法
 String host = "10.10.100.254";
 int port = 8899;
 String request = "GET / HTTP/1.1\r\nHost: 10.10.100.254\r\nConnection: close\r\n\r\n";
 InetSocketAddress mAddress;
 System.out.println("正在连接到 " + host + ":" + port);
 String response = createSocketConnection(host, port, request);
 System.out.println("服务器响应:\n" + response);
 }

 /**
 * 创建Socket连接并发送请求
 * @param host 服务器主机名或IP地址
 * @param port 服务器端口号
 * @param request 要发送的请求数据
 * @return 服务器响应数据
 */
 public static String createSocketConnection(String host, int port, String request) {
 Socket socket = null;
 BufferedReader in = null;
 PrintWriter out = null;
 StringBuilder response = new StringBuilder();

 try {
 System.out.println("Socket连接: " );
 // 创建Socket连接
 socket = new Socket(host, port);
 System.out.println("Socket连接成功: " + socket);

 // 获取输出流,用于向服务器发送数据
 out = new PrintWriter(socket.getOutputStream(), true);

 // 获取输入流,用于读取服务器响应
 in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

 // 发送请求
 out.println(request);

 // 读取响应
 String line;
 while ((line = in.readLine()) != null) {
 response.append(line).append("\n");
 }

 } catch (UnknownHostException e) {
 System.err.println("无法解析主机: " + host);
 e.printStackTrace();
 } catch (IOException e) {
 System.err.println("IO错误: " + e.getMessage());
 e.printStackTrace();
 } finally {
 // 关闭资源
 try {
 if (in != null) in.close();
 if (out != null) out.close();
 if (socket != null) socket.close();
 System.out.println("Socket连接已关闭");
 } catch (IOException e) {
 System.err.println("关闭资源时出错: " + e.getMessage());
 }
 }

 return response.toString();
 }
}