java实时通信聊天程序
惘者 人气:0利用TCP传输数据,编写客户端和服务器的程序,实现两个程序间的实时通信。
在每个程序中实现了实时的发送与接收数据的功能。
客户端的io界面
服务器端的io界面
io演示
程序以两端分别输入close字符串作为结束标识。在一端输入close时,终止发送、一端接收到close时,终止接收。所演示的客户端来自个人电脑IDEA调试运行。服务器端来自阿里云服务器centos系统下的jdk环境。该程序需要用到java的 I/O 流、多线程、网络编程的相关知识。
一、客户端
由于发送和接收数据是并行的,为了使得时刻都能同时进行接受与发送的功能,使用多线程,将接收和发送分别封装为两个Runnable实现类。获取io信息。
ClientDemo类的源码:
public class ClientDemo { public static Socket s; public static void main(String[] args) throws IOException, InterruptedException { s = new Socket("localhost", 10000); //此处的参数一填写服务器端ip地址 System.out.println("连接成功"); Thread send = new Thread(new COUT()); Thread receive = new Thread(new CIN()); send.start(); receive.start(); send.join(); //发送和接收执行完毕时,关闭套接字 receive.join(); //因此待这两个线程结束时才回到主线程执行。 s.close(); } }
创建全局变量套接字s,在主进程中给s进行初始化,然后启动发送和接收功能的两个线程。
Socket构造时传递的两个参数,其一填写服务器地址。或者填写localhost即127.0.0.1回送地址,本机即可运行服务器端和客户端进行本地数据传输。
其二是端口数,需要保持客户端和服务器端的套接字绑定的端口数一致。尽可能选用数量大的端口以免被占用,如果运行时报错端口已占用可以尝试更改端口数,范围在65536内。
客户端发送和接收类的源码:
class CIN implements Runnable{ @Override public void run() { //接收模块 try { InputStream is = ClientDemo.s.getInputStream();//通过全局套接字s获取连接后的流 in(is); } catch (IOException o) { o.printStackTrace(); } } public static void in(InputStream is) throws IOException{ while(true){ byte[] bytes = new byte[1024]; int len = is.read(bytes); String line = new String(bytes,0,len); System.out.println("对方: "+line); if(line.equals("close")) break; } } } class COUT implements Runnable{ @Override public void run() { //发送模块 try { OutputStream os = ClientDemo.s.getOutputStream();//套接字获取流 out(os); } catch (IOException o){ o.printStackTrace(); } } public static void out(OutputStream os) throws IOException{ Scanner sc = new Scanner(System.in); while(true) { String line = sc.nextLine(); os.write(line.getBytes()); if(line.equals("close")) break; } sc.close(); } }
由于IO流都由socket创建,因此程序结束时需要关闭s即可。
二、服务器
ServerDemo类的源码:
public class ServerDemo { public static ServerSocket ss; public static Socket s; public static void main(String[] args) throws IOException, InterruptedException { ss = new ServerSocket(10000); //监听端口10000,对应客户端套接字绑定的端口 s = ss.accept(); //提取监听套接字中的一个连接 System.out.println("连接成功"); Thread send = new Thread(new SOUT()); Thread receive = new Thread(new SIN()); send.start(); receive.start(); send.join(); receive.join(); ss.close(); } }
创建服务器套接字对象并监听,并接收连接请求。
此处的代码与客户端大同小异,完成连接后的代码基本一致。
服务器端发送和接收类的源码:
class SIN implements Runnable{ @Override public void run() { try { InputStream is = ServerDemo.s.getInputStream(); in(is); } catch (IOException o) { o.printStackTrace(); } } public static void in(InputStream is) throws IOException{ while(true){ byte[] bytes = new byte[1024]; int len = is.read(bytes); String line = new String(bytes,0,len); System.out.println("对方: "+line); if(line.equals("close")) break; } } } class SOUT implements Runnable{ @Override public void run() { try { OutputStream os = ServerDemo.s.getOutputStream(); out(os); } catch (IOException o){ o.printStackTrace(); } } public static void out(OutputStream os) throws IOException{ Scanner sc = new Scanner(System.in); while(true) { String line = sc.nextLine(); os.write(line.getBytes()); if(line.equals("close")) break; } sc.close(); } }
两者代码不同的地方在于由于套接字不同,返回的流实例不同。基本逻辑相同。
本地可同时运行客户端和服务器端,客户端套接字绑定本地ip地址,“localhost或127.0.0.1。
先开启服务器端进行监听,然后打开客户端向服务器端发起连接请求。连接成功后即可实时进行聊天。在程序中以一行为信息单元,键入若干字符后换行发送。另一端即可收到信息。
在一端键入“close”发送即可关闭当前程序的发送线程和接收程序的接收线程。待两个程序的所有发送和接收都结束时,关闭程序。
实测记录:将服务器端程序发送至云服务器通过jdk运行,并开启程序监听,将客户端的套接字指向服务器端的地址和监听端口。之后建立连接,可自由在两端传输信息。
加载全部内容