资源简介

之前已经做了一个版本:http://download.csdn.net/download/onlyxiahui/9347191 不过功能太少了,于是继续完善了下,主要增加了群聊、表情发送、来消息后头像和系统托盘跳动、图片发送、窗口抖动、视频聊天等。不过视频聊天问题比较多,毕竟这只是写着玩。

资源截图

代码片段和文件信息

package com.oim.app;

import org.apache.log4j.Logger;

import com.oim.business.handler.PersonalHandler;
import com.oim.common.app.controller.ControllerFactory;
import com.oim.common.app.handler.SendHandler;
import com.oim.common.app.handler.SendHandlerFactory;
import com.oim.common.app.manage.Manage;
import com.oim.common.app.manage.ManageFactory;
import com.oim.common.app.service.Service;
import com.oim.common.app.service.ServiceFactory;
import com.oim.common.app.view.AbstractView;
import com.oim.common.app.view.ViewFactory;
import com.oim.common.task.ExecuteTask;
import com.oim.common.task.QueueTaskThread;
import com.oim.net.connect.MessageHandler;
import com.oim.net.connect.SocketConnector;
import com.oim.net.server.Handler;
import com.oim.net.thread.HeadPulseThread;
import com.oim.ui.view.LoginView;
import com.only.net.action.ConnectBackAction;
import com.only.net.action.ConnectStatusAction;
import com.only.net.connect.ConnectThread;
import com.only.net.connect.WriteHandler;
import com.only.net.data.Data;
import com.only.net.data.action.DataBackAction;
import com.only.net.data.action.DataSentAction;
import com.only.net.data.bean.HandlerData;
import com.only.net.thread.DataReadThread;
import com.only.net.thread.DataWriteThread;

/**
 * 这是程序的上下文,方便各个模块之间调用
 * 
 * @author XiaHui
 * @date 2015年3月6日 上午9:30:30
 */
public class AppContext {
protected final Logger logger = Logger.getLogger(this.getClass().getName());

private Handler handler;//负责处理TCP接受到的消息
private SocketConnector connector;//连接实体
private ConnectThread connectThread;//处理连接的线程
private DataReadThread dataReadThread;//处理回掉信息的线程
private DataWriteThread dataWriteThread;//处理发送信息的线程
private ControllerFactory controllerFactory;
private ViewFactory viewFactory = new ViewFactory(this);
private ServiceFactory serviceFactory = new ServiceFactory(this);
private ManageFactory manageFactory = new ManageFactory(this);
private SendHandlerFactory sendHandlerFactory = new SendHandlerFactory(this);
private HeadPulseThread headPulseThread = new HeadPulseThread();//处理头像跳动的线程
private QueueTaskThread queueTaskThread = new QueueTaskThread();//用于执行一些耗时的线程任务
private boolean login = false;//用来标识是否已经成功登录了

public AppContext() {
long time = System.currentTimeMillis();
initApp();
System.out.println(“initApp“ + (System.currentTimeMillis() - time));
initAction();
System.out.println(“initAction“ + (System.currentTimeMillis() - time));
}

/**
 * 初始化各个模块
 */
private void initApp() {

controllerFactory = new ControllerFactory(this);
handler = new Handler();
connector = new SocketConnector(handler);

dataWriteThread = new DataWriteThread();// 数据发送线程
dataReadThread = new DataReadThread();//负责消息回掉的线程
connectThread = new ConnectThread();

connectThread.setConnector(connector);

handler.setControllerFactory(controllerFactory);
handler.addMessageHandler(new MessageHandler() {

@Override
publi

评论

共有 条评论