var wsUri = "ws://localhost/Websocket/IMSer...">
devbox
Monodyee
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

websocket简介和java实例

作者：Monodyee | 2024-03-16 11:13:09

赞

踩

websocket简介和java实例

目录

1.websocket 简介

2.实例

2.1前台接、发消息

2.2后台发消息

2.3完整项目下载

1.websocket 简介

     简介传送门

2.实例

2.1前台接、发消息

   前台页面代码

  1.  
  2. <script type="text/javascript">
  3.  
  4. var wsUri = "ws://localhost/Websocket/IMServer?userid=rz_${rybh}&username=${XM}";
  5. var socket = new WebSocket(wsUri);
  6. //发送消息
  7. socket.send(message);
  8. //websocket建立连接
  9. socket.onopen = function(evt) {
  10.  
  11. };
  12. //websocket监听接收消息
  13. socket.onmessage = function(evt) {
  14.  
  15. }
  16.  
  17. </script>

IMserver.java

  1. package com.test;
  2.  
  3. import java.io.IOException;
  4. import java.io.UnsupportedEncodingException;
  5. import java.net.URLDecoder;
  6. import java.util.HashMap;
  7. import java.util.Map;
  8.  
  9. import javax.websocket.OnClose;
  10. import javax.websocket.OnMessage;
  11. import javax.websocket.OnOpen;
  12. import javax.websocket.Session;
  13. import javax.websocket.server.ServerEndpoint;
  14.  
  15. import com.google.gson.Gson;
  16.  
  17. /**
  18.  * 桌面窗口对话服务端 
  19.  * 标识   userid+DESKSERVER
  20.  *
  21.  */
  22. @ServerEndpoint("/IMServer")
  23. public class EchoServer {
  24. 	String fgf="###"; //分隔符
  25. 	private String toUser;
  26. 	
  27. 	private String userid;//消息发送人id
  28. 	private String username;//消息发送人姓名
  29. 	private String fromUser;
  30.     private String hyid;//会话id
  31.     
  32. 	public String getHyid() {
  33. 		return hyid;
  34. 	}
  35.  
  36. 	public void setHyid(String hyid) {
  37. 		this.hyid = hyid;
  38. 	}
  39.  
  40. 	public String getUserid() {
  41. 		return userid;
  42. 	}
  43.  
  44. 	public void setUserid(String userid) {
  45. 		this.userid = userid;
  46. 	}
  47.  
  48. 	public String getUsername() {
  49. 		return username;
  50. 	}
  51.  
  52. 	public void setUsername(String username) {
  53. 		this.username = username;
  54. 	}
  55.  
  56. 	public String getFromUser() {
  57. 		return fromUser;
  58. 	}
  59.  
  60. 	public void setFromUser(String fromUser) {
  61. 		this.fromUser = fromUser;
  62. 	}
  63.  
  64. 	public String getToUser() {
  65. 		return toUser;
  66. 	}
  67.  
  68. 	public void setToUser(String toUser) {
  69. 		this.toUser = toUser;
  70. 	}
  71.  
  72. 	@OnOpen
  73. 	public void initSession(Session session) throws UnsupportedEncodingException {
  74. 		this.setToUser(session.getRequestParameterMap().get("toUser").get(0));
  75. 		this.setUserid(session.getRequestParameterMap().get("userid").get(0));		 
  76. this.setUsername(URLDecoder.decode(session.getRequestParameterMap().get("username").get(0)+"","UTF-8"));
  77. 		this.setHyid(session.getRequestParameterMap().get("hyid").get(0));
  78.  
  79. 		SessionMap.sessions.put(this.getUserid()+"DESKSERVER", session);//DESKSERVER桌面聊天设置
  80. 		//SessionUtil.sessions.add(session);
  81. 	}
  82. 	
  83. 	@OnMessage
  84. 	public void echo(String incomingMessage){
  85. //		System.err.println("发送消息内容:"+incomingMessage);
  86. 		String hyids=this.getToUser();
  87. 		if(null!=hyids&&!"".equals(hyids)){
  88. 			
  89. 			String[] ryids = hyids.split(",");
  90. 			for(int i=0;i<ryids.length;i++){
  91. //				System.err.println("发送消息给::"+ryids[i]);
  92. 				Session session=SessionMap.sessions.get(ryids[i]);
  93. 				String[] incomingMessages=incomingMessage.split(fgf);
  94. 				if(session!=null){
  95. 					Map<String, Object> map=new HashMap<String, Object>();
  96. 					map.put("Msgsdate",incomingMessages[1]);//消息发送时间
  97. 					map.put("Msgsreturnid",incomingMessages[2]);//消息id
  98. 					map.put("Msgs",incomingMessages[0]);//消息
  99. 					map.put("SenderId", this.getUserid());//发送人id
  100. 					map.put("SenderName", this.getUsername());//发送人姓名
  101. 					map.put("hyid", this.getHyid());//发送人姓名
  102. 					String json=new Gson().toJson(map);
  103. 					sendMessage(session, json);
  104. 				 }
  105. 			}
  106. 		}
  107. 	}
  108. 		
  109.  
  110. 	private void sendMessage(Session session, String msg) {
  111. 		try {
  112. 			session.getBasicRemote().sendText(msg);
  113. 		} catch (IOException e) {
  114. 			e.printStackTrace();
  115. 		}	
  116. 	}
  117.  
  118. //	@OnError
  119. //	public void processError(Session session){
  120. //		SessionUtil.sessions.remove(session);
  121. //	}
  122.  
  123. 	@OnClose
  124. 	public void processClose(Session session){
  125. 		SessionMap.sessions.remove(this.getUserid()+"DESKSERVER");
  126. 	}
  127. 	
  128. }

结合 layim

  1. layui.use('layim',function(layim) {
  2.  
  3. 	//基础配置
  4. 	layim.config({
  5.  
  6. 		//或采用以下方式初始化接口
  7. 		//或采用以下方式初始化接口
  8. 		init : {
  9. 			url : '${ctx}/api/layui/lxrlist',
  10. 			data : {}
  11. 		}
  12. 		//查看群员接口
  13. 		,members : {
  14. 			url : '${ctx}/api/layui/qzrylist',
  15. 			data : {}
  16. 		}
  17. 		//上传图片接口
  18. 		,
  19. 		uploadImage : {
  20. 			url : '${ctx}/api/layui/fileUpload' //（返回的数据格式见下文）
  21. 			,
  22. 			type : '' //默认post
  23. 		}
  24. 		//上传文件接口
  25. 		,
  26. 		uploadFile : {
  27. 			url : '${ctx}/api/layui/fileUploadfile' //（返回的数据格式见下文）
  28. 			,
  29. 			type : '' //默认post
  30. 		}
  31. 		//扩展工具栏
  32. 		// 		    ,tool: [{
  33. 		// 		      alias: 'code'
  34. 		// 		      ,title: '代码'
  35. 		// 		      ,icon: '&#xe64e;'
  36. 		// 		    }]
  37. 		//,brief: true //是否简约模式（若开启则不显示主面板）
  38. 		,
  39. 		title : '即时通讯' //自定义主面板最小化时的标题
  40. 		//,right: '100px' //主面板相对浏览器右侧距离
  41. 		//,minRight: '90px' //聊天面板最小化时相对浏览器右侧距离
  42. 		,
  43. 		//right: '15%', //主面板相对浏览器右侧距离
  44.         //minRight: '200px',//用户控制聊天面板最小化时、及新消息提示层的相对right的px坐标。
  45. 		initSkin : '3.jpg' //1-5 设置初始背景
  46. 		//,skin: ['aaa.jpg'] //新增皮肤
  47. 		//,isfriend: false //是否开启好友
  48. 		,
  49. 		isgroup : true //是否开启群组
  50. 		,
  51. 		min : true //是否始终最小化主面板，默认false
  52. 		,
  53. 		notice : true //是否开启桌面消息提醒，默认false
  54. 		,
  55. 		voice : false //声音提醒，默认开启，声音文件为：default.wav
  56. 		,
  57. 		copyright : true
  58. 		// ,msgbox: layui.cache.dir + 'css/modules/layim/html/msgbox.html' //消息盒子页面地址，若不开启，剔除该项即可
  59. 		//,find: layui.cache.dir + 'css/modules/layim/html/find.html' //发现页面地址，若不开启，剔除该项即可
  60. 		,
  61. 		chatLog : layui.cache.dir+ 'css/modules/layim/html/chat.jsp' //聊天记录页面地址，若不开启，剔除该项即可
  62.  
  63. 	});
  64.  
  65. 	/* var cache =  layui.layim.cache();
  66. 	var local = layui.data('layim')[cache.mine.id]; //获取当前用户本地数据
  67. 	 
  68. 	//这里以删除本地聊天记录为例
  69. 	delete local.chatlog;
  70. 	 
  71. 	//向localStorage同步数据
  72. 	layui.data('layim', {
  73. 	  key: cache.mine.id
  74. 	  ,value: local
  75. 	}); */
  76. 	
  77. 	
  78. 	//监听在线状态的切换事件
  79. 	layim.on('online', function(data) {
  80. 		//console.log(data);
  81. 	});
  82.  
  83. 	//监听签名修改
  84. 	layim.on('sign', function(value) {
  85. 		//console.log(value);
  86. 	});
  87.  
  88. 	//监听自定义工具栏点击，以添加代码为例
  89. 	// 		  layim.on('tool(code)', function(insert){
  90. 	// 		    layer.prompt({
  91. 	// 		      title: '插入代码'
  92. 	// 		      ,formType: 2
  93. 	// 		      ,shade: 0
  94. 	// 		    }, function(text, index){
  95. 	// 		      layer.close(index);
  96. 	// 		      insert('[pre class=layui-code]' + text + '[/pre]'); //将内容插入到编辑器
  97. 	// 		    });
  98. 	// 		  });
  99.  
  100. 	//监听layim建立就绪
  101. 	layim.on('ready', function(res) {
  102. 		//console.log(res.mine);
  103. 		//layim.msgbox(5); //模拟消息盒子有新消息，实际使用时，一般是动态获得
  104. 		setTimeout(function() {
  105. 			var obj = {};
  106. 			//接受消息（如果检测到该socket）
  107. 		}, 3000);
  108. 	});
  109. 	// 打开layim时建立websocket服务端连接
  110.    var wsUri = "ws://localhost/Websocket/IMServer?userid=rz_${rybh}&username=${XM}";
  111.    var socket = new WebSocket(wsUri);
  112. 	//监听发送消息
  113. 	layim.on('sendMessage', function(data) {
  114. 		var To = data.to;
  115. 		if (To.type === 'friend') {
  116. 			socket.send(data.to.id + "#@@#" + JSON.stringify(data));  //websocket 发送消息
  117. 		}
  118.        //发送消息内容持久化
  119. 		$.ajax({
  120. 			type : 'post',
  121. 			data : {
  122. 				key : JSON.stringify(data)
  123. 			},
  124. 			url : '${ctx}/api/layui/sendmessage',
  125. 			success : function(val) {
  126. 			}
  127. 		});
  128.  
  129. 	});
  130.     //websocket建立连接
  131. 	socket.onopen = function(evt) {
  132. 	};
  133.    //websocket监听接收消息
  134. 	socket.onmessage = function(evt) {
  135. 		evt = JSON.parse(evt.data);
  136. 			layim.getMessage({
  137. 				username : evt.mine.username, //消息来源用户名
  138. 				avatar : evt.mine.avatar, //消息来源用户头像
  139. 				id : evt.mine.id, //消息的来源ID（如果是私聊，则是用户id，如果是群聊，则是群组id）
  140. 				type : evt.to.type, //聊天窗口来源类型，从发送消息传递的to里面获取
  141. 				content : evt.mine.content, //消息内容
  142. 				cid : 0, //消息id，可不传。除非你要对消息进行一些操作（如撤回）
  143. 				mine : false, //是否我发送的消息，如果为true，则会显示在右方
  144. 				fromid : evt.mine.id //消息的发送者id（比如群组中的某个消息发送者），可用于自动解决浏览器多窗口时的一些问题
  145. 				timestamp : new Date().getTime()//服务端动态时间戳
  146. 			});
  147. 	};
  148. 	socket.onerror = function(evt) {
  149. //			console.log("ERROR!!!!");
  150. 		//writeToScreen('<span style="color: red;">ERROR:</span> ' + evt.data);
  151. 		//socket.close();
  152. 	};
  153.  
  154. 	//监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。
  155. 	window.onbeforeunload = function () {
  156. 		socket.close();
  157. 	};
  158. 	//监听查看群员
  159. 	layim.on('members', function(data) {
  160. 		//console.log(data);
  161. 	});
  162. 	//监听聊天窗口的切换
  163. 	layim.on('chatChange', function(res) {
  164. 		var type = res.data.type;
  165. 	});
  166.  
  167. });

2.2后台发消息

MyClient.java     websocket客户端 

  1. package com.utils.websocket;
  2.  
  3. import javax.websocket.ClientEndpoint;  
  4. import javax.websocket.OnClose;
  5. import javax.websocket.OnError;  
  6. import javax.websocket.OnMessage;  
  7. import javax.websocket.OnOpen;  
  8. import javax.websocket.Session;  
  9.  
  10. @ClientEndpoint  
  11. public class MyClient {  
  12.     @OnOpen  
  13.     public void onOpen(Session session) {  
  14.     }  
  15.     @OnMessage  
  16.     public void onMessage(String message) {  
  17.     }  
  18.     @OnClose
  19.     public void processClose(Session session){
  20.     	
  21.     }
  22.     @OnError  
  23.     public void onError(Throwable t) {  
  24.         t.printStackTrace();  
  25.     }  
  26. }

ConnToServer.java   连接websocket服务端

  1. package com.utils.websocket;
  2.  
  3. import java.io.IOException;
  4. import java.net.URI;
  5. import java.net.URISyntaxException;
  6.  
  7. import javax.websocket.ContainerProvider;
  8. import javax.websocket.DeploymentException;
  9. import javax.websocket.Session;
  10. import javax.websocket.WebSocketContainer;
  11.  
  12. public class ConnToServer {
  13.  
  14. 	public Session session;
  15.  
  16. 	/**
  17. 	 * 连接websocket server 
  18. 	 * @param uri
  19. 	 */
  20. 	public void start(String uri) {
  21. 		WebSocketContainer container = ContainerProvider.getWebSocketContainer();
  22.  
  23. 		try {
  24. 			session = container.connectToServer(MyClient.class, new URI(uri));
  25. 		} catch (DeploymentException e) {
  26. 			e.printStackTrace();
  27. 		} catch (IOException e) {
  28. 			e.printStackTrace();
  29. 		} catch (URISyntaxException e) {
  30. 			e.printStackTrace();
  31. 		}
  32. 	}
  33. }

PushMsg.java      消息发送工具类

  1. package com.test.push;
  2.  
  3. import java.net.URI;
  4. import java.net.URLEncoder;
  5. import java.util.Iterator;
  6. import java.util.List;
  7. import java.util.Map;
  8. import java.util.Map.Entry;
  9.  
  10. import org.apache.log4j.Logger;
  11.  
  12. import com.fasterxml.jackson.dataformat.yaml.snakeyaml.util.UriEncoder;
  13. import com.utils.websocket.ConnToServer;
  14.  
  15. /**
  16.  * 消息发送工具类
  17.  * 
  18.  * @author Administrator
  19.  * 
  20.  */
  21. public final class PushMsg {
  22.  
  23. 	private PushMsg(){};
  24. 	
  25. 	private static Logger logger = Logger.getLogger(PushMsg.class);
  26.  
  27. 	/**给指定的人发送消息提醒
  28. 	 * 
  29. 	 * @param message (消息内容)
  30. 	 * @param userId (发送对象)
  31. 	 */
  32. 	public static void sendMessage(Message message) {
  33. 		try {
  34. 			// 推送消息
  35.             List<Map<String, Object>> list=message.getMsgDatas();
  36.             if(!list.isEmpty()&&list.size()>0){
  37.          	   Map<String, Object> map=list.get(0);
  38.          	   String username=map.get("xm")+"";
  39.                    String sender=map.get("sender")+"";
  40.          	   String reciver=map.get("reciver")+"";
  41.          	   String content=map.get("content")+"";
  42.          	   username=URLEncoder.encode(username,"UTF-8");
  43.                //建立连接，发送消息
  44.          	   String uri = "ws://localhost:1234/websocket/echo?sender="+sender+"&username="+username+"&reciver="+reciver;
  45.          	   ConnToServer cts=new ConnToServer();
  46.          	   cts.start(uri);//
  47.          	   cts.session.getBasicRemote().sendText(content);
  48.          	   cts.session.close();
  49.             }
  50. 			
  51. 		} catch (Exception e) {
  52. 			logger.error(e.getCause());
  53. 		}
  54. 	}
  55.  
  56. }

2.3完整项目下载

   

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Monodyee/article/detail/249104
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号