java 即时通信,java开发即时通讯客户端
利用TCP传输数据，编写了客户端和服务器端程序，实现了两个程序之间的实时通信。
每个程序都实现了实时发送和接收数据的功能。
客户端的Io接口
服务器的Io接口
Io演示
在程序的两端输入结束字符串作为结束标记。一端输入close，发送终止，另一端收到close，接收终止。演示的客户端来自于调试和运行个人电脑的想法。服务器来自阿里云服务器centos系统下的jdk环境。这个程序需要用到java的I/O流，多线程和网络编程知识。
00-1010由于发送和接收数据是并行的，为了使接收和发送的功能同时进行，使用多线程将接收和发送分别封装到两个可运行的实现类中。获取io信息。
ClientDemo类的源码：
公共类ClientDemo {公共静态套接字s；public static void main(String[]args)抛出IOException，interrupted exception { s=new Socket( localhost ，10000)；//这里参数一填写服务器ip地址System.out.println(连接成功)；Thread send=新线程(new COUT())；Thread receive=new Thread(新CIN())；send . start()；receive . start()；send . join()；//发送和接收完成后关闭socket receive . join()；//所以要等到这两个线程结束，再返回主线程执行。s . close()；}}创建全局变量sockets，在主进程中初始化S，然后启动发送和接收函数的两个线程。
套接字构造期间传递了两个参数，其中一个填充服务器地址。或者填入localhost，也就是127.0.0.1环回地址，这台机器就可以运行服务器和客户端进行本地数据传输。
第二是端口数，需要保持客户端和服务器的套接字绑定的端口数一致。尽量选择尽可能多的端口，避免被占用。如果运行时报告端口被占用，您可以尝试更改端口的数量。范围是65536。
客户端发送和接收类的源码：
类实现runnable { @ override public void run(){//接收模块try { inputstream is=client demo . s . getinputstream()；//通过全局套接字S在(is)中获取连接的流；} catch(io exception o){ o . printstacktrace()；} } public static void in(InputStream is)抛出io exception { while(true){ byte[]bytes=new byte[1024]；int len=is.read(字节)；String line=新字符串(bytes，0，len)；System.out.println(对方： 行)；if(line.equals(close ))中断；}}} classcout实现runnable { @ override public void run(){//发送模块try { output stream OS=client demo . s . get output stream()；//socket get stream out(OS)；} catch(io exception 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运行，并开启程序监听，将客户端的套接字指向服务器端的地址和监听端口。之后建立连接，可自由在两端传输信息。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持盛行IT。
郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。