Java socket模拟聊天程序


根据TCP/IP协议，通过socket实现网络聊天，分为服务器端和客户端，一下是参考程序。

服务器端程序：

package com.michael.contact;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
public static void main(String args[]) throws IOException {
String reces = null;
int len;
Socket socket = null;
OutputStream outputstream = null;
InputStream inputstream = null;
byte[] rece = new byte[1000];
try {
ServerSocket serversocket = new ServerSocket(8888); // 服务器的套接字，端口为8888
while (true) {
socket = serversocket.accept();
inputstream = socket.getInputStream();// 得到输入流
outputstream = socket.getOutputStream();// 得到输出流
len = inputstream.read(rece);// 接受客户端消息
if (len != 0)
reces = new String(rece, 0, len);
System.out.println(reces);
BufferedReader bufferreader = new BufferedReader(new InputStreamReader(System.in));
outputstream.write(("服务器....." + bufferreader.readLine()).getBytes());// 返回给客户端的欢迎信息
}
} catch (Exception e) {
e.printStackTrace();
} finally {
inputstream.close();
outputstream.close();
socket.close();// 记住一定要关闭这些输入，输出流和套接字
}

}
}

客户端程序：

package com.michael.contact;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
public class Client {
public static void main(String[] args) throws IOException {
String ServerIpAddress = "127.0.0.1";// 对方的IP
String words = "Hello";// 对方的话
String temp = null;
byte[] serverSay = new byte[1000];// 读取<1KB
InputStreamReader read = null;
int len = 0;
Socket s = null;
OutputStream outputstream = null;
InputStream inputstream = null;
// 取得你给他的IP
System.out.println("请输入对方的IP(默认发给自己):");
read = new InputStreamReader(System.in);
try {
temp = new BufferedReader(read).readLine();
if (!temp.equals(""))
ServerIpAddress = temp;
} catch (IOException e1) {
}
// 取得你各他的Message
System.out.println("请输入想对他(她)说的话----输入QUIT 退出!!:");
read = new InputStreamReader(System.in);
while (true) {
try {
temp = "Hello";
temp = new BufferedReader(read).readLine();
words = temp;
if (words.equals("quit"))
break;
temp = "客户端....." + words;
// 发起通信
s = new Socket(InetAddress.getByName(ServerIpAddress), 8888);// 套接字的IP地址和端口号
outputstream = s.getOutputStream();
inputstream = s.getInputStream();
outputstream.write(temp.getBytes("gbk"));// 向服务器发送消息
len = inputstream.read(serverSay);// 接受服务器消息
System.out.println( new String(serverSay, 0, len));// 客户端控制台显示服务器返回的信息
} catch (Exception e) {
} finally {
inputstream.close();
outputstream.close();
s.close();// 记住一定要关闭这些输入，输出流和套接字
}
}// end while
}
}