PHP/Java即时通讯源码下载 - 开源IM系统开发指南与定制服务

+---------------------+     +---------------------+     +---------------------+
|     客户端层        |<--->|    通讯协议层       |<--->|  实时通讯服务层(Java) |
| (APP/Web/PC)       |     | (WebSocket/Socket.IO)|     |  (Netty服务器)       |
+---------------------+     +---------------------+     +---------------------+
                                                               ^
                                                               | 消息队列(RabbitMQ)
                                                               v
+---------------------+     +---------------------+     +---------------------+
|     业务逻辑层(PHP) |<--->|    数据接口层       |<--->|    数据存储层       |
| (API接口/业务逻辑)  |     | (数据访问抽象层)    |     | (MySQL/Redis/Mongo) |
+---------------------+     +---------------------+     +---------------------+

java
package com.im.server;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
import io.netty.handler.stream.ChunkedWriteHandler;
import io.netty.handler.timeout.IdleStateHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.concurrent.TimeUnit;

/
 * 即时通讯服务器主类
 * 基于Netty框架构建WebSocket服务器
 */
public class ImServer {
    private static final Logger logger = LoggerFactory.getLogger(ImServer.class);
    
    // 服务器端口
    private int port;
    // 服务器工作线程组
    private EventLoopGroup bossGroup;
    private EventLoopGroup workerGroup;
    
    public ImServer(int port) {
        this.port = port;
    }
    
    /
     * 启动服务器
     */
    public void start() {
        try {
            bossGroup = new NioEventLoopGroup(1);  // 主反应器线程组
            workerGroup = new NioEventLoopGroup(); // 工作线程组
            
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class)
             .option(ChannelOption.SO_BACKLOG, 1024)
             .childOption(ChannelOption.SO_KEEPALIVE, true)
             .childHandler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 protected void initChannel(SocketChannel ch) throws Exception {
                     // HTTP编解码器
                     ch.pipeline().addLast(new HttpServerCodec());
                     // 支持大文件传输
                     ch.pipeline().addLast(new ChunkedWriteHandler());
                     // 聚合HTTP消息
                     ch.pipeline().addLast(new HttpObjectAggregator(65536));
                     // 空闲连接检测(10秒无读、30秒无写则判定为空闲)
                     ch.pipeline().addLast(new IdleStateHandler(10, 30, 0, TimeUnit.SECONDS));
                     // WebSocket协议处理器，指定WebSocket路径
                     ch.pipeline().addLast(new WebSocketServerProtocolHandler("/im"));
                     // 自定义消息处理器
                     ch.pipeline().addLast(new ImWebSocketHandler());
                 }
             });
            
            // 绑定端口，启动服务器
            ChannelFuture f = b.bind(port).sync();
            logger.info("即时通讯服务器已启动，监听端口: " + port);
            
            // 等待服务器关闭
            f.channel().closeFuture().sync();
        } catch (InterruptedException e) {
            logger.error("服务器启动异常", e);
        } finally {
            workerGroup.shutdownGracefully();
            bossGroup.shutdownGracefully();
            logger.info("服务器已关闭");
        }
    }
    
    /
     * 主方法
     */
    public static void main(String[] args) {
        int port = 8080;
        if (args.length > 0) {
            port = Integer.parseInt(args[0]);
        }
        new ImServer(port).start();
    }
}