(2) websocket 实现群聊

1 开发环境请见 "基于tomcat7和jdk1.7的websocket启动 " ，另外源码下载地址为 : http://download.csdn.net/detail/jianfpeng241241/9323549

2 项目结构图

3 Message.java

package com.web.message;import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;import com.google.gson.Gson;/** 定义传播的信息的结构* */
public class Message {private String content;private String welcome;private List<String> usernames;private static Gson gson = new Gson();public String getWelcome() {return welcome;}public Message(){}public Message(String welcome,List<String> usernames){this.welcome = welcome;this.usernames = usernames;}public void setWelcome(String welcome) {this.welcome = welcome;}public List<String> getUsernames() {return usernames;}public void setUsernames(List<String> usernames) {this.usernames = usernames;}public String toJson(){return gson.toJson(this);}public String getContent() {return content;}public void setContent(String content,String username) {SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String time = sdf.format(new Date());this.content = "\r\n\r\n" +time +"\r\n" +username+" said : " + content;}public static void main(String args[]){SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String time = sdf.format(new Date());System.out.println(time);}
}

4 Login.java

package com.web.servlet;import java.io.IOException;
import java.io.PrintWriter;import javax.servlet.RequestDispatcher;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;public class Login extends HttpServlet {/*** Constructor of the object.*/public Login() {super();}/*** Destruction of the servlet. <br>*/public void destroy() {super.destroy(); // Just puts "destroy" string in log// Put your code here}public void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {String username = request.getParameter("username");
//      System.out.println("username = " + username);request.setAttribute("username", username);RequestDispatcher dispatcher = request.getRequestDispatcher("/chart.jsp"); dispatcher.forward(request, response);}public void doPost(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {}/*** Initialization of the servlet. <br>** @throws ServletException if an error occurs*/public void init() throws ServletException {// Put your code here}}

5 EchoSocket.java

package com.webSocket.client;import java.io.IOException;
import java.util.ArrayList;
import java.util.List;import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;import com.web.message.Message;@ServerEndpoint("/echo")
public class EchoSocket {private static List<String> usernames = new ArrayList<String>();private static List<Session> sessions = new ArrayList<Session>();private String username; private Session session;@OnOpenpublic void open(Session session){ //打开websocketSystem.out.println("userid = "+session.getId());String string = session.getQueryString();this.username = string.split("=")[1];this.usernames.add(this.username);this.sessions.add(session);String welcome = "欢迎"+this.username+"加入聊天室";Message message = new Message(welcome,this.usernames);this.broadcast(this.sessions,message.toJson());}@OnClosepublic void close(Session session){ //关闭websocketthis.sessions.remove(session);this.usernames.remove(this.username);String goMsg = this.username+"已经离开聊天室";Message message = new Message(goMsg,this.usernames);this.broadcast(this.sessions,message.toJson());System.out.println("websocket is close");}@OnMessagepublic void message(Session session,String msg){//接收客服端信息//System.out.println("客服端信息为 : " + message);if (session.isOpen()) {Message message = new Message();message.setUsernames(this.usernames);message.setContent(msg,this.username);this.broadcast(this.sessions,message.toJson());}}public List<String> getUsernames() {return usernames;}public List<Session> getSessions() {return sessions;}private  void broadcast(List<Session> sessionsList,String msg) { //广播给其它人if(sessionsList.size() > 0){for(int i = 0 ; i < sessionsList.size() ; i++){try {sessionsList.get(i).getBasicRemote().sendText(msg);} catch (IOException e) {System.out.println("EchoSocket.java broadcast method ,广播失败 ");e.printStackTrace();}}}}}

6 DemeConfig.java

package com.webSocket.config;import java.util.Set;import javax.websocket.Endpoint;
import javax.websocket.server.ServerApplicationConfig;
import javax.websocket.server.ServerEndpointConfig;public class DemeConfig implements ServerApplicationConfig{//注解的方式 启动public Set<Class<?>> getAnnotatedEndpointClasses(Set<Class<?>> scan) {System.out.println("-------------websoket start-----------------");System.out.println("scan.size() = " + scan.size());return scan; //必须要返回scan,否则会造成连接失败}//接口方式启动public Set<ServerEndpointConfig> getEndpointConfigs(Set<Class<? extends Endpoint>> arg0) {return null;}}

7 web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"><servlet><description>This is the description of my J2EE component</description><display-name>This is the display name of my J2EE component</display-name><servlet-name>Login</servlet-name><servlet-class>com.web.servlet.Login</servlet-class></servlet><servlet-mapping><servlet-name>Login</servlet-name><url-pattern>/servlet/Login</url-pattern></servlet-mapping><welcome-file-list><welcome-file>login.jsp</welcome-file></welcome-file-list>
</web-app>

8 chart.jsp

<%@ page language="java" import="java.util.*,javax.*" pageEncoding="utf-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%><!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html><head><title>My JSP 'index.jsp' starting page</title></head><body><script type="text/javascript">var ws=null; var target = "ws://"+window.location.host+"/webSocketTest/echo?username=${requestScope.username}"; // 打开管道  ,ws://localhost:8080/项目名/@ServerEndpoint名字window.οnlοad=function(){if(ws==null){if ('WebSocket' in window) {ws = new WebSocket(target);} else if ('MozWebSocket' in window) {ws = new MozWebSocket(target);} else {alert('WebSocket is not supported by this browser.');return;}ws.onmessage = function (event) { //创建websocket同时,接收服务器发给客服端的消息if(event!=null){//将json字符串转为对象eval("var msg="+event.data+";"); //得到对象里面的值var welcome = msg.welcome;var content = msg.content;var usernames = msg.usernames;//为聊天区teaxarea赋值var textArea = document.getElementById("content");if(undefined!=welcome){textArea.value = textArea.value  + "\r\n"+welcome;}if(undefined!=content){textArea.value = textArea.value  + "\r\n"+content;}//为用户列表区TD赋值var userListTD = document.getElementById("userList");userListTD.innerHTML="";for(var i = 0 ; i < usernames.length; i++){if(undefined!=usernames[i]){if("${requestScope.username}" == usernames[i]){userListTD.innerHTML += "\r\n  <span style='color: red'>" +  usernames[i]+"</span></br>";}else{userListTD.innerHTML += "\r\n" +  usernames[i]+"</br>";}}}}};}};sendMessage = function(){ //发送信息if(ws!=null){var sendMessageInput = document.getElementById("sendMessageTextArea");var msg = sendMessageInput.value;ws.send(msg);sendMessageInput.value ="";}else{alert("websocket is null , please create a websocket");}}</script><table cellpadding="0" cellspacing="0"  border="1" width="500px" height="400px"><tr><td><textarea id="content" rows="10" cols=50"></textarea></td><td id="userList" width="150px" align="center"></td></tr><tr><td colspan="2"><textarea id="sendMessageTextArea" rows="5" cols=50"></textarea><button οnclick="sendMessage()">发送</button></td></tr></table></body>
</html>

9 login.jsp

<%@ page language="java" import="java.util.*" pageEncoding="utf-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%><!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html><head><title>login</title></head><body><form action="<%=request.getContextPath()%>/servlet/Login" method="get">用户名:<input type="text" name="username"/><input type="submit" value="登录"/></form></body>
</html>

(2) websocket 实现群聊相关推荐

springboot整合websocket实现群聊
1.依赖 2.websocket配置: 3.前端 4.注意事项效果: 也可以打开新窗口连接一个新用户发消息 1.依赖 <dependency><groupId>org.spr ...
SpringBoot实战之整合WebSocket之群聊
SpringBoot实战之整合WebSocket 文章目录 SpringBoot实战之整合WebSocket 前言一.WebSocket简介二.WebSocket原理三.WebSocket特点 ...
websocket实现群聊
群聊转载于:https://www.cnblogs.com/caodneg7/p/10177344.html
Swoole实现基于WebSocket的群聊私聊
本文属于入门级文章,大佬们可以绕过啦.如题,本文会实现一个基于Swoole的websocket聊天室(可以群聊,也可以私聊,具体还需要看数据结构的设计). 搭建Swoole环境通过包管理工具 # 安 ...
Android中脱离WebView使用WebSocket实现群聊和推送功能
WebSocket是Web2.0时代的新产物,用于弥补HTTP协议的某些不足,不过他们之间真实的关系是兄弟关系,都是对socket的进一步封装,其目前最直观的表现就是服务器推送和聊天功能.更多知识参考 ...
Spring Boot整合websocket实现群聊，点对点聊天,图片发送，音频发送
参考:基于https://blog.csdn.net/qq_38455201/article/details/80374712 基础上进行添加图片发送和音频发送功能单点图片发送: 单点音频发送: ...
Flask+geventwebsocket实现群聊与单聊功能
Flask+WebSocket 实现群聊与单聊功能群聊 py文件 from flask import Flask ,request,render_template from geventwebsoc ...
websocket学习和群聊实现
WebSocket协议可以实现前后端全双工通信,从而取代浪费资源的长轮询.在此协议的基础上,可以实现前后端数据.多端数据,真正的实时响应.在学习WebSocket的过程中,实现了一个简化版群聊,过程和 ...
js 链接websocket马上断开_WebSocket之基于STOMP协议的广播模式实现群聊功能
又是一个老套的古诗词赏析不恨此花飞尽,恨西园.落红难缀.--苏轼<水龙吟·次韵章质夫杨花词> WebSocket与STOMP协议相关简介 WebSocket WebSocket 是一种 ...

(2) websocket 实现群聊

(2) websocket 实现群聊相关推荐

最新文章

热门文章