使用socket实现服务器客户端即时通讯的小例子

package com.huaqin.test;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class ClientTest {
public static void main(String[] args) {
try {
ServerSocket s = new ServerSocket(2536);
Socket incoming = s.accept();
System.out.println("incoming come ");

BufferedReader in = new BufferedReader(new InputStreamReader(
incoming.getInputStream()));
PrintWriter out = new PrintWriter(incoming.getOutputStream(), true);
out.println("Hello! Enter BYE to exit.");

boolean done = false;
Scanner scanner = new Scanner(System.in);
System.out.println("***********begin************");

while (!done) {

String line = in.readLine();
System.out.println("来信：" + line);
String str = scanner.next();
if (line == null) {
done = true;
} else {
out.println(str);
if (line.trim().equals("BYE")) {
done = true;
}
}
}
incoming.close();
} catch (Exception e) {
System.out.println(e);
}
}

}

package com.java.test;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Scanner;

public class Client {
public static void main(String args[]) {
try {

Socket connection;

connection = new Socket("192.168.126.68", 2536);
BufferedReader input = new BufferedReader(new InputStreamReader(
connection.getInputStream()));

PrintWriter out = new PrintWriter(connection.getOutputStream(),true );
String info;
Scanner ss=new Scanner(System.in);

while (true) {
info = input.readLine();
System.out.println("来信: "+info);

String str=ss.next();
out.println(str);
System.out.println("发送:"+str);

}
connection.close();
}
catch (SecurityException e) {
System.out.println("SecurityException when connecting Server!");
}
catch (IOException e) {
System.out.println("IOException when connecting Server!");
}
}
}