pushlet实现webQQ即时通信

后台维护界面展现：

                                                                 后台首页

 

 

 

                                                      账户及其人员列表

 

人员的组织及其所在群组的维护页面就不在展现下面展现客户端。

 

                     用户登录

 

               鼠标悬停

 

 

                  维护状态

 

 

                   鼠标右键

 

 

                                               查看人员信息

 

 

 

                                            查看聊天记录

 

 

                                          维护个人资料

 

 

 

                                           聊天窗口

 

 

 

                                         互相附件传送

 

 

                 IM实现消息提醒

 

                                  实现群组之间的聊天

 

以上是IM（即时通信）一些基本功能的简介，好了就先到此为止吧。。。。。

在Pushlet的应用方面希望可以与大家相互交流，互相学习。

 

 

 

 

JavaScript两种发送消息的方式不用多说

1、Ajax保持心跳的即时通信

2、往前台输送HTML的即时通信

 

下面贴Java实现即时通信的代码

package com.jlee.im;

import java.util.Map;

import nl.justobjects.pushlet.client.PushletClient;
import nl.justobjects.pushlet.client.PushletClientListener;
import nl.justobjects.pushlet.core.Event;
import nl.justobjects.pushlet.core.Protocol;


public class SystemChatEngine extends Thread implements PushletClientListener, Protocol {
//	private static SystemChatEngine  systemChatEngine = new SystemChatEngine("http://localhost:8888/im/pushlet.srv");

	private static SystemChatEngine engine = null ;
	private PushletClient pushletClient;
	private Map<String ,String> attributemap ;
	private String aHosturl=null;
	private String SUBJECT = "/pushlet/ping";
	private String imSubject = null;

	private SystemChatEngine(String aHosturl, String subject, String imSubject, Map<String ,String> map) {
		this.aHosturl = aHosturl;
		this.SUBJECT = subject ;
		this.attributemap = map ;
		this.imSubject = imSubject ;
	}
	
	public static SystemChatEngine getInstance(String aHosturl, String subject ,String imSubject ,Map<String ,String> map){
		if(engine==null){
			engine = new SystemChatEngine(aHosturl,subject,imSubject,map) ;
			engine.start() ;
		}
		return engine ;
	}
	
	public void run() {
		try {

			pushletClient = new PushletClient(aHosturl);
			pushletClient.setDebug(false);
			
			pushletClient.setUid(attributemap.get("uid")) ;
			
			pushletClient.join();
			pushletClient.listen(this, Protocol.MODE_PULL,SUBJECT);

			System.out.println("pushletClient started");
			
			pushletClient.publish(imSubject, attributemap);
			
		} catch (Exception e) {
			e.printStackTrace();
			return;
		}
	}

	/** Error occurred. */
	public void onError(String message) {
		System.out.println(message);
	}

	/** Abort event from server. */
	public void onAbort(Event theEvent) {
	}

	/** Data event from server. */
	public void onData(Event theEvent) {
		String meSessionID = theEvent.getField("uid");
	}

	/** Heartbeat event from server. */
	public void onHeartbeat(Event theEvent) {
	}

	public void onRefresh(Event theEvent) {
	}

	public void onJoinListenAck(Event theEvent) {
		String meSessionID = theEvent.getField("uid");
	}

	public void onListenAck(Event theEvent) {
		String meSessionID = theEvent.getField("uid");
	}

	/**
	 * @return pushletClient
	 */
//	public static  PushletClient getPushletClient() {
//		while(systemChatEngine.pushletClient==null){}
//		return systemChatEngine.pushletClient;
//	}

	/** Main program. */
//	public static void main(String args[]) {
//		systemChatEngine.start();
//	}

}

 

 

 

package com.jlee.im;

import java.util.HashMap;
import java.util.Map;

import sun.misc.BASE64Encoder;

public class WebIMClient {

	static SystemChatEngine engine = null ;
	
	public void sendTask()throws Exception{
		
		Map<String ,String> attributemap = new HashMap<String, String>() ;
		BASE64Encoder encoder = new BASE64Encoder();
		String fromName = encoder.encode("jlee".getBytes("utf-8")) ;
		String message = java.net.URLEncoder.encode(
				encoder.encode(
						"<a href='#' title='http://www.baidu.com' name='alabel'>baidu</a>去百度查IM".getBytes("utf-8"))) ;
		String remark = encoder.encode("备注".getBytes("utf-8")) ;
		
		String title = encoder.encode("主题1".getBytes("utf-8")) ;
		String msgType = encoder.encode("类型1".getBytes("utf-8")) ;
		String msgGroup = encoder.encode("self".getBytes("utf-8")) ;//self(表示消息来自系统OA)或者other（消息来自其他系统）
		
		attributemap.put("uid" ,"728852348a9f4c219f9666facef19356") ;//该字段不会进入数据库，只是充当Pushlet所依赖的Id
		attributemap.put("fromId", "728852348a9f4c219f9666facef19356") ;
		attributemap.put("fromName", fromName) ;
		attributemap.put("toId", "86523b57993048a0b82bd06772e432dd") ;
		attributemap.put("toGroupId", null) ;
		attributemap.put("message", message) ;
		attributemap.put("remark", remark) ;

		attributemap.put("title", title) ;
		attributemap.put("msgType", msgType) ;
		attributemap.put("msgGroup", msgGroup) ;
		
		engine = SystemChatEngine.getInstance(
				"http://localhost:8888/im/pushlet.srv", "/pushlet/ping,/task/warn","/task/warn", attributemap) ;
		
	}
	
	public static void main(String[] args) {
		WebIMClient client = new WebIMClient() ;
		try {
			client.sendTask() ;
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

 

评论

5 楼 need_faith 2013-06-08  

"JavaScript两种发送消息的方式不用多说
1、Ajax保持心跳的即时通信
2、往前台输送HTML的即时通信"
不是很明白，
楼主说的两种方式其实是一种吧，
前台往后台发送消息，用户出发发送按钮的相关js，通过ajax发送；
响应文回写到前端（刷新本地已经发送的消息），完成一次通信；
其他用户给当前用户发送消息，采用的是轮询吧，每个多长时间去服务器请求一遍

没有推送，消息不能及时送达

4 楼 yehao0716 2013-06-08  

没有jar包

3 楼 willsonbin 2012-11-20  

如何运行起来？

2 楼 xumin198908 2012-03-13  

学习了！！！！！！

1 楼 need_faith 2011-10-08  

不错的文章