基于JAVA网络编程的聊天小程序

时间:2024-01-01 19:07:57
 package com.neusoft.edu.socket;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 服务器端代码
* 获取客户端发送的信息,显示并且返回对应的回复
* 1、创建ServerSocket对象
* 2、调用accept方法获取客户端连接
* 3、使用输入流读取客户端发送的数据
* 4、使用输出流向客户端写入数据
* 5、关闭对应的对象
* @author L
*
*/
public class ChatServer {
/**
* @param args
*/
public static void main(String[] args) {
try {
//1、创建ServerSocket对象,8875为自定义端口号
ServerSocket server = new ServerSocket(8857); //简单提示
System.out.println("等待客户端连接……"); //2、获取客户端连接
Socket client = server.accept(); //获取客户端的相关信息
System.out.println(client.getInetAddress().getHostAddress() + "连接上来了……"); //3.1、定义输入流和输出流对象
BufferedReader in = new BufferedReader(
new InputStreamReader(
client.getInputStream())); //用来获取从控制台输入的数据,将该数据发送给客户端
BufferedReader inByServer = new BufferedReader(
new InputStreamReader(System.in)); PrintWriter out = new PrintWriter(client.getOutputStream(), true); //读取到的数据
String data = null;
String answer = null; //循环和客户端进行通信
do
{
//3.2、读取客户端发送的数据
data = in.readLine(); //在服务器端显示读取到的数据
System.out.println("客户端发送信息:" + data); //获取服务器端要发送给客户端的信息
System.out.print("服务器端回复客户端:");
answer = inByServer.readLine(); //3.3、将数据写入到客户端
out.println(answer);
out.flush();
}while(!"bye".equals(data)); //4、关闭相关资源
out.flush();
in.close();
inByServer.close();
out.close(); //关闭Socket对象
client.close();
server.close(); System.out.println("服务器端关闭……");
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
 package com.neusoft.edu.socket;

 import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException; /**
* 聊天客户端
* 1、创建Socket对象
* 2、写入数据
* 3、读取从服务器端发来的数据
* 4、关闭
* @author L
*
*/
public class ChatClient { /**
* @param args
*/
public static void main(String[] args) {
try {
//1、创建Socket对象,("192.168.1.107", 8857)分别为主机IP和端口号,两个类端口号要一致
Socket client = new Socket("192.168.1.107", 8857); //2.1、创建输入流和输出流对象
BufferedReader in = new BufferedReader(
new InputStreamReader(
client.getInputStream())); PrintWriter out = new PrintWriter(client.getOutputStream(), true); BufferedReader inByClient = new BufferedReader(
new InputStreamReader(System.in)); //服务器端发送的数据
String data = null;
//客户端向服务器端写入的数据
String answer = null; do
{
//2.2、客户端的读写操作
System.out.print("你说:");
//获取要发送给服务器端的数据
answer = inByClient.readLine();
//向服务器端写入数据
out.println(answer);
out.flush(); //获取服务器端发送的数据
data = in.readLine();
//输出从服务器端获取的数据
System.out.println("服务器端返回信息是:" + data);
}while(!"bye".equals(data)); //3、关闭
in.close();
out.close();
inByClient.close();
client.close(); System.out.println("客户端关闭……");
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} }

这是个小程序,不过也包含了一些小BUG,仅供新手参考,不妥之处,还望见谅!