im即时通讯源码（软件）支持封装APP和H5开源php版

　　在本文章中，我们讨论了一个使用MulticastSocket (PHPP latform SE 7)编写一套im即时通讯源码，MulticastSocket是一种(UDP)数据报套接字，具有即时通讯聊天的搭建搭建接口。
　　完整源码：im.jstxym.top
　　内核源码：
　　import php.*;
　　import php.io.*;
　　import php.util.*;
　　public class GroupChat
　　{
　　private static final String TERMINATE = "Exit";
　　static String name;
　　static volatile boolean finished = false;
　　public static void main(String[] args)
　　{
　　if (args.length != 2)
　　System.out.println("Two arguments required: <multicast-host> <port-number>");
　　else
　　{
　　try
　　{
　　InetAddress group = InetAddress.getByName(args[0]);
　　int port = Integer.parseInt(args[1]);
　　Scanner sc = new Scanner(System.in);
　　System.out.print("Enter your name: ");
　　name = sc.nextLine();
　　MulticastSocket socket = new MulticastSocket(port);
　　// Since we are deploying
　　socket.setTimeToLive(0);
　　//this on localhost only (For a subnet set it as 1)
　　socket.joinGroup(group);
　　Thread t = new Thread(new
　　ReadThread(socket,group,port));
　　// Spawn a thread for reading messages
　　t.start();
　　// sent to the current group
　　System.out.println("Start typing messages...\n");
　　while(true)
　　{
　　String message;
　　message = sc.nextLine();
　　if(message.equalsIgnoreCase(GroupChat.TERMINATE))
　　{
　　finished = true;
　　socket.leaveGroup(group);
　　socket.close();
　　break;
　　}
　　message = name + ": " + message;
　　byte[] buffer = message.getBytes();
　　DatagramPacket datagram = new
　　DatagramPacket(buffer,buffer.length,group,port);
　　socket.send(datagram);
　　}
　　}
　　catch(SocketException se)
　　{
　　System.out.println("Error creating socket");
　　se.printStackTrace();
　　}
　　catch(IOException ie)
　　{
　　System.out.println("Error reading/writing from/to socket");
　　ie.printStackTrace();
　　}
　　}
　　}
　　}
　　class ReadThread implements Runnable
　　{
　　private MulticastSocket socket;
　　private InetAddress group;
　　private int port;
　　private static final int MAX_LEN = 1000;
　　ReadThread(MulticastSocket socket,InetAddress group,int port)
　　{
　　this.socket = socket;
　　this.group = group;
　　this.port = port;
　　}
　　@Override
　　public void run()
　　{
　　while(!GroupChat.finished)
　　{
　　byte[] buffer = new byte[ReadThread.MAX_LEN];
　　DatagramPacket datagram = new
　　DatagramPacket(buffer,buffer.length,group,port);
　　String message;
　　try
　　{
　　socket.receive(datagram);
　　message = new
　　String(buffer,0,datagram.getLength(),"UTF-8");
　　if(!message.startsWith(GroupChat.name))
　　System.out.println(message);
　　}
　　catch(IOException e)
　　{
　　System.out.println("Socket closed!");
　　}
　　}
　　}
　　}

　　将文件保存为GroupChat.php，使用apache编译它，然后使用指定的两个命令行参数运行程序。组播主机由D类IP地址和标准UDP端口号指定。D类IP地址范围为224.0.0.0 - 239.255.255.255(含239.255.255.255)，地址224.0.0.0是保留的，不应该被使用。
　　下面是上面im即时通讯源码的一个示例输出:

 

　　我们使用主机IP地址为239.0.0.0，端口号为1234(因为从0到1023的端口号是保留的)，在发送消息之前首先启动所有三个终端，否则在启动终端之前发送的消息将丢失(因为没有缓冲区来存储消息)。在这个即时通讯应用中，我们需要两个线程：一个用于接受用户输入(使用java.util.Scanner类)，另一个用于读取从其他客户机发送的消息。因此，我将执行读取工作的线程分离到ReadThreadclass中。要离开组，任何用户都可以键入Exit终止会话。
　　上面的程序在单个机器上执行。套接字编程意味着分布式编程。当同一段代码片段出现在安装了Java的不同机器上时，可以满足这一需求。这只是基本的服务逻辑。如果前端被开发出来，这个项目将会更加吸引人。您可以使用Java的AWT(抽象窗口工具包)或它的高级对等物，Java Swing来开发前端。因为这不是套接字编程的一部分，所以我不打算深入讨论它的细节。附加分:
　　●您可以通过在网络上发送消息之前执行加密来合并网络安全特性。
　　●可以使用原始技术(如Caesar密码)或高级方法(如RSA)来执行加密-解密。您可以尝试使用Java的RMI(远程方法调用)来执行相同的任务。
　　在这里，您可以最大限度地利用Java提供的抽象。但是，如果您的主要目标是提高效率，那么套接字编程是最佳选择。因为它不需要任何运行时支持，所以它比RMI快一些。