TCP实现的聊天代码

声明：以下代码仅供初学者了解端口操作用，不能作为正式的代码，里面有许多的可以优化的地方。但作为入门例子足够了！

package chat;

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;

/**
 * TCP 发送数据的代码。
 *
 * @author 赵学庆 www.java2000.net
 */
public class TCPSendTest {
  public static void main(String[] args) {
    TCPSendTest app = new TCPSendTest();
    app.display();
  }

  void display() {
    Socket s;
    byte buf[] = new byte[256];
    int count;
    byte[] host = new byte[128];
    try {
      // 输入目的方的主机名
      System.out.print("请输入目的方的主机名: ");
      count = System.in.read(host);
      InetAddress addr = InetAddress.getByName(new String(host, 0, count - 2));
      while (true) {
        System.out.print("请输入要发送的数据: ");
        count = System.in.read(buf);
        // 发送数据报
        s = new Socket(addr.getHostAddress(), 8888);
        InputStream is = s.getInputStream();
        BufferedReader reader = new BufferedReader(new InputStreamReader(is));
        PrintWriter out = new PrintWriter(s.getOutputStream());
        out.println(new String(buf, 0, count - 2));
        out.flush();
        String line = reader.readLine();
        System.out.print("返回信息: ");
        System.out.println(line);
        reader.close();
        out.close();
        s.close();
      }
    } catch (Exception e) {
      System.out.println(e);
    }
  }
}

package chat;

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;

/**
 * TCP 发送数据的代码。
 * 
 * @author 赵学庆 www.java2000.net
 */
public class TCPSendTest {
  public static void main(String[] args) {
    TCPSendTest app = new TCPSendTest();
    app.display();
  }

  void display() {
    Socket s;
    byte buf[] = new byte[256];
    int count;
    byte[] host = new byte[128];
    try {
      // 输入目的方的主机名
      System.out.print("请输入目的方的主机名: ");
      count = System.in.read(host);
      InetAddress addr = InetAddress.getByName(new String(host, 0, count - 2));
      while (true) {
        System.out.print("请输入要发送的数据: ");
        count = System.in.read(buf);
        // 发送数据报
        s = new Socket(addr.getHostAddress(), 8888);
        InputStream is = s.getInputStream();
        BufferedReader reader = new BufferedReader(new InputStreamReader(is));
        PrintWriter out = new PrintWriter(s.getOutputStream());
        out.println(new String(buf, 0, count - 2));
        out.flush();
        String line = reader.readLine();
        System.out.print("返回信息: ");
        System.out.println(line);
        reader.close();
        out.close();
        s.close();
      }
    } catch (Exception e) {
      System.out.println(e);
    }
  }
}

package chat;

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * TCP 接收数据的代码。
 *
 * @author 赵学庆 www.java2000.net
 */
public class TCPReceiveTest {
  void display() {
    ServerSocket socket;
    try {
      socket = new ServerSocket(8888);
      while (true) {
        Socket s = socket.accept();
        InputStream is = s.getInputStream();
        BufferedReader reader = new BufferedReader(new InputStreamReader(is));
        PrintWriter out = new PrintWriter(s.getOutputStream());
        String line = reader.readLine();
        System.out.println("接收到来自 " + s.getRemoteSocketAddress() + " 数据:");
        System.out.println(line);
        out.print("OK");
        out.flush();
        out.close();
        reader.close();
        s.close();
      }
    } catch (Exception e) {
      System.out.println(e);
    }
  }

  public static void main(String[] args) {
    TCPReceiveTest app = new TCPReceiveTest();
    app.display();
  }
}