web即時通訊2--基於Spring websocket實現web聊天室

阿新 • • 發佈：2019-02-09

本文使用Spring4和websocket搭建一個web聊天室，框架基於SpringMVC+Spring+Hibernate的Maven專案，後臺使用spring websocket進行訊息轉發和聊天訊息快取。客戶端使用socket.js和stomp.js來進行訊息訂閱和訊息傳送。詳細實現見下面程式碼。

首先在pom.xml中新增對spring websocket的相關依賴包。

一、新增websocket依賴

<span style="font-size:14px;">             <dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-webmvc</artifactId>
			<version>${springframework.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-websocket</artifactId>
			<version>${springframework.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-messaging</artifactId>
			<version>${springframework.version}</version>
		</dependency>
		<dependency>
			<groupId>org.apache.poi</groupId>
			<artifactId>poi</artifactId>
			<version>3.9</version>
		</dependency>
             <dependency>  
                <groupId>com.fasterxml.jackson.core</groupId>  
                <artifactId>jackson-core</artifactId>  
                <version>2.3.0</version>  
            </dependency>  
            <dependency>  
                <groupId>com.fasterxml.jackson.core</groupId>  
                <artifactId>jackson-databind</artifactId>  
                <version>2.3.0</version>  
            </dependency>  
            <dependency>  
                <groupId>com.fasterxml.jackson.core</groupId>  
                <artifactId>jackson-annotations</artifactId>  
                <version>2.3.0</version>  
            </dependency>   
</span>

其中<springframework.version>4.0.3.RELEASE</springframework.version>。因為spring4以上才支援WebSocket。

2、配置Spring WebSocket

該配置可以在Spring MVC的配置檔案配置，也可以使用註解方式配置，本文使用註解@Configuration方式進行配置。

<span style="font-size:14px;">package com.test.chat.controller;

import java.util.List;

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.converter.MessageConverter;
import org.springframework.messaging.simp.config.ChannelRegistration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketTransportRegistration;

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer{
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        //新增這個Endpoint，這樣在網頁中就可以通過websocket連線上服務了
        registry.addEndpoint("/webchat").withSockJS();
    }
     
    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        System.out.println("伺服器啟動成功");
        //這裡設定的simple broker是指可以訂閱的地址，也就是伺服器可以傳送的地址
        config.enableSimpleBroker("/userChat","/initChat","/initFushionChart","/updateChart","/videoChat");  
        config.setApplicationDestinationPrefixes("/app");   
    }

    @Override
    public void configureClientInboundChannel(ChannelRegistration channelRegistration) {
    }

    @Override
    public void configureClientOutboundChannel(ChannelRegistration channelRegistration) {
    }

	@Override
	public void configureWebSocketTransport(
			WebSocketTransportRegistration registry) {
		// TODO Auto-generated method stub
		System.out.println("registry:"+registry);
	}

	@Override
	public boolean configureMessageConverters(
			List<MessageConverter> messageConverters) {
		// TODO Auto-generated method stub
		System.out.println("messageConverters:"+messageConverters);
		return true;
	}
}
</span>

要使配置檔案生效，需在Spring的檔案中能夠掃描到該檔案所在的包。即配置<context:component-scan base-package="com.test.**.controller" />

3、聊天內容的實體物件和後臺關鍵程式碼

<span style="font-size:14px;">package com.test.chat.model;

public class ChatMessage {
	//房間號
	private String roomid;
	//使用者名稱
	private String userName;
	//機構名
	private String deptName;
	//當前系統時間
	private String curTime;
	//聊天內容
	private String chatContent;
	//是否是系統訊息
	private String isSysMsg;
	
	public String getIsSysMsg() {
		return isSysMsg;  
	}
	public void setIsSysMsg(String isSysMsg) {
		this.isSysMsg = isSysMsg;
	}
	public String getRoomid() {
		return roomid;
	}
	public void setRoomid(String roomid) {
		this.roomid = roomid;
	}
	public String getUserName() {
		return userName;
	}
	public void setUserName(String userName) {
		this.userName = userName;
	}
	public String getDeptName() {
		return deptName;
	}
	public void setDeptName(String deptName) {
		this.deptName = deptName;
	}
	public String getCurTime() {
		return curTime;
	}
	public void setCurTime(String curTime) {
		this.curTime = curTime;
	}
	public String getChatContent() {
		return chatContent;
	}
	public void setChatContent(String chatContent) {
		this.chatContent = chatContent;
	}

}
</span>

後臺關鍵處理程式碼，用於轉發訊息並快取聊天記錄

<span style="font-size:14px;">package com.test.chat.controller;

import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

import javax.annotation.Resource;
import javax.servlet.http.HttpSession;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.handler.annotation.DestinationVariable;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.messaging.simp.annotation.SubscribeMapping;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;

import com.alibaba.fastjson.JSONObject;
import com.test.chat.model.ChatMessage;
import com.test.chat.model.LimitQueue;
import com.test.chat.model.VideoMessage;
import com.test.framework.common.SessionContainer;
import com.test.framework.service.GenericService;
import com.test.framework.utils.DateUtil;

@Controller
public class UserChatController {
        //每個聊天室快取最大聊天資訊條數，該值由SpringMVC的配置檔案注入，超過該值將清理出快取
	private int MAX_CHAT_HISTORY;

	public void setMAX_CHAT_HISTORY(int MAX_CHAT_HISTORY) {
		this.MAX_CHAT_HISTORY = MAX_CHAT_HISTORY;
	}

	@Resource
	private GenericService genericService;
	// 用於轉發資料 sendTo
	private SimpMessagingTemplate template;
        //訊息快取列表
        private Map<String, Object> msgCache = new HashMap<String, Object>();

	@Autowired
	public UserChatController(SimpMessagingTemplate t) {
		template = t;
	}


	/**
	 * WebSocket聊天的相應接收方法和轉發方法
	 * 客戶端通過app/userChat呼叫該方法，並將處理的訊息傳送客戶端訂閱的地址
	 * @param userChat     關於使用者聊天的各個資訊
	 */
	@MessageMapping("/userChat")
	public void userChat(ChatMessage chatMessage) {
		// 找到需要傳送的地址(客戶端訂閱地址)
		String dest = "/userChat/chat" + chatMessage.getRoomid();
		// 獲取快取，並將使用者最新的聊天記錄儲存到快取中
		Object cache = msgCache.get(chatMessage.getRoomid());
		try {
			chatMessage.setRoomid(URLDecoder.decode(chatMessage.getRoomid(),"utf-8"));
			chatMessage.setUserName(URLDecoder.decode(chatMessage.getUserName(), "utf-8"));
			chatMessage.setDeptName(URLDecoder.decode(chatMessage.getDeptName(), "utf-8"));
			chatMessage.setChatContent(URLDecoder.decode(chatMessage.getChatContent(), "utf-8"));
			chatMessage.setIsSysMsg(URLDecoder.decode(chatMessage.getIsSysMsg(),"utf-8"));
			chatMessage.setCurTime(DateUtil.format(new Date(),DateUtil.formatStr_yyyyMMddHHmmss));
		} catch (UnsupportedEncodingException e) {
			e.printStackTrace(); 
		}
		// 傳送使用者的聊天記錄
		this.template.convertAndSend(dest, chatMessage);
                ((LimitQueue<ChatMessage>) cache).offer(chatMessage);
	}

	
	@SubscribeMapping("/initChat/{roomid}")
	public LimitQueue<ChatMessage> initChatRoom(@DestinationVariable String roomid) {
		System.out.print("-------新使用者進入聊天室------");
		LimitQueue<ChatMessage> chatlist = new LimitQueue<ChatMessage>(MAX_CHAT_HISTORY);
		// 傳送使用者的聊天記錄
		if (!msgCache.containsKey(roomid)) {
			// 從來沒有人進入聊天空間
			msgCache.put(roomid, chatlist);
		} else {
			chatlist = (LimitQueue<ChatMessage>) msgCache.get(roomid);
		}
		return chatlist;
	}
	
}
</span>

在Spring的配置檔案中注入MAX_CHAT_HISTRORY

<span style="font-size:14px;">    <bean id="userChatController" class="com.test.chat.controller.UserChatController">
        <property name="MAX_CHAT_HISTORY" value="20"/>
    </bean>       </span>

其中快取佇列LimitQueue的實現為：

<span style="font-size:14px;">package com.test.chat.model;

import java.util.Collection;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.Queue;

public class LimitQueue<E> implements Queue<E> {
	private int limit;
	private Queue<E> queue;

	public LimitQueue(int limit) {
		this.limit = limit;
		this.queue = new LinkedList<E>();
	}

	@Override
	public int size() {
		return queue.size();
	}

	@Override
	public boolean isEmpty() {
		return queue.isEmpty();
	}

	@Override
	public boolean contains(Object o) {
		return queue.contains(o);
	}

	@Override
	public Iterator<E> iterator() {
		return queue.iterator();
	}

	@Override
	public Object[] toArray() {
		return queue.toArray();
	}

	@Override
	public <T> T[] toArray(T[] a) {
		return queue.toArray(a);
	}

	@Override
	public boolean add(E e) {
		return queue.add(e);
	}

	@Override
	public boolean remove(Object o) {
		return queue.remove(0);
	}

	@Override
	public boolean containsAll(Collection<?> c) {
		return queue.containsAll(c);
	}

	@Override
	public boolean addAll(Collection<? extends E> c) {
		return queue.addAll(c);
	}

	@Override
	public boolean removeAll(Collection<?> c) {
		return queue.removeAll(c);
	}

	@Override
	public boolean retainAll(Collection<?> c) {
		return queue.retainAll(c);
	}

	@Override
	public void clear() {
		queue.clear();
	}

	@Override
	public boolean offer(E e) {
		if (queue.size() >= limit) {
			queue.poll();
		}
		return queue.offer(e);
	}

	@Override
	public E remove() {
		return queue.remove();
	}

	@Override
	public E poll() {
		return queue.poll();
	}

	@Override
	public E element() {
		return queue.element();
	}

	@Override
	public E peek() {
		return queue.peek();
	}

	public int getLimit() {
		return this.limit;
	}
}
</span>

四、前臺聊天室的實現（前臺介面使用dhtmlx控制元件）

<span style="font-size:14px;"><%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
	<head>
		<title>聊天室管理</title>
		<meta http-equiv="content-type" content="text/html; charset=utf-8" /> 
		<link rel="stylesheet" type="text/css" href="/dhtmlx/dhtmlxEditor/codebase/skins/dhtmlxeditor_dhx_skyblue.css">
		<script src="/common/js/lib-base.js" type="text/javascript"></script> 
		<script src="/dhtmlx/dhtmlxEditor/codebase/dhtmlxeditor.js" type="text/javascript"></script>
		<!-- <script src="/dhtmlx/dhtmlxEditor/codebase/ext/dhtmlxeditor_ext.js" type="text/javascript"></script> -->
		<!-- web chat 引入相關指令碼 -->
		<script src="/common/js/websocket/sockjs-0.3.4.min.js" type="text/javascript"></script>
		<script src="/common/js/websocket/stomp.js" type="text/javascript"></script>
		<!----------------end------------------->
		<script>  
	var chatLayout; 
	var roomid="${roomid}";  
	var roomName=null;
	var friendTree=null;
	var userid=null;
	var username=null; 
	var deptSortName=null;
	var editor=null;
	$(function(){   
		commonForm.initForm(); 
		chatLayout= new dhtmlXLayoutObject(document.body, "3J");
		ajaxPost("/chatroom/findById",{"id":roomid},function(data,status){
			chatLayout.cells("a").setText("<img src='/images/Pub/User.gif' width='16px' height='16px' align='absmiddle' style='margin-right:5px'>"+data.roomName);
			roomName=data.roomName;
			$("#roomRemark").html(data.remark); 
		}) ;  
		chatLayout.cells("a").hideHeader(); 
		chatLayout.cells("a").attachObject("chatMsg");
		chatLayout.cells("c").setHeight(150); 
		chatLayout.cells("c").hideHeader();     
		chatLayout.setAutoSize("a;c","a;b");   
        chatLayout.cells("b").setWidth(180); 
        var friendLayout=chatLayout.cells("b").attachLayout("2E"); 
        friendTree=friendLayout.cells("b").attachTree(); 
        friendLayout.cells("a").setText("<img src='/images/Pub/User.gif' width='16px' height='16px' align='absmiddle' style='margin-right:5px'>群公告");
        friendLayout.cells("a").attachObject("roomRemark");
        friendLayout.cells("a").setHeight(100);
        friendLayout.cells("b").setText("<img src='/images/Pub/User.gif' width='16px' height='16px' align='absmiddle' style='margin-right:5px'>好友列表");
        friendLayout.setAutoSize("a;b","b");  
        //載入好友列表樹 
        ajaxPost("/auth/getCurUser",null,function(data,status){
        	userid=data.id;
        	username=data.name;
        	deptSortName=data.deptSortName;
        }) 
        loadChatFriend();
        //載入聊天
        var talkLayout=chatLayout.cells("c").attachLayout("2E");
        talkLayout.cells("a").hideHeader();
        talkLayout.cells("b").hideHeader();
        talkLayout.cells("b").setHeight(29); 
        //dhtmlx.image_path="/dhtmlx/dhtmlxEditor/codebase/imgs/";   
        editor=talkLayout.cells("a").attachEditor(); 
        var toolbar=talkLayout.cells("b").attachToolbar();
        toolbar.setIconsPath("/images/Pub/");
        var tbindex=0; 
		toolbar.addSeparator("sep1", tbindex++);  
		toolbar.addSpacer("sep1"); 
		toolbar.addButton("closeChat", tbindex++, "關閉", "delete.png","delte.png");
		toolbar.addSeparator("sep2",tbindex++);  
		toolbar.addButton("videoChat", tbindex++, "視訊", "FrameReLogin.gif","FrameReLogin.gif");
		toolbar.addSeparator("sep3",tbindex++);  
		toolbar.addButton("sendMessage", tbindex++, "傳送", "redo.gif","redo.gif");
		
		toolbar.attachEvent("onclick",function(tid){
			switch(tid){
				case "sendMessage":
					if(editor.getContent()=="" )
						return;
					sendMessage("0");
					editor.setContent("");   
					break; 
				case "closeChat":  
					sendMessage("1","離開"); 
					parent.dhxWins.window("chatWin").close();
					break;  
				case "videoChat": 
        			top.openWindow("/video/openVideoChat?roomid="+roomid,"videoWin","聊天室【"+roomName+"】",650,550,false,false,true);
					break; 
				default: 
					break; 
			} 
		})   
		   
        
	});  
	
	function loadChatFriend(){
		 friendTree.setSkin('dhx_skyblue');   
		 friendTree.setImagePath("/dhtmlx/dhtmlxTree/codebase/imgs/csh_dhx_skyblue/");
		 ajaxPost("/chatroom/getChatFriends",{"roomid":roomid},function(data,status){
			 friendTree.deleteChildItems(friendTree.rootId); 
			 $.each(data,function(index,item){
				 var id=item.user.id;
				 var deptName=item.user.corg.shortName;
				 var userName=item.user.name;
				 var isCreator=item.isCreator;
				 friendTree.insertNewItem(friendTree.rootId,id,deptName+"--"+userName+(isCreator=="1"?"（群主）":""),0,0,0,0,"");
				 if(userid==id)
				     friendTree.setItemColor(id,"red","");
			 })    
		})  
	}
	
	 //---------------------------------------聊天室關鍵程式碼（websocket）---------------------------------------
	 var stompClient=null;content=null;
	 $(function(){
		 connect();
	 })
	 //connect the server
	 function connect(){
		 var socket=new SockJS("/webchat"); 
		 stompClient=Stomp.over(socket);
		 stompClient.connect('','',function(frame){
			 console.log('Connected: '+frame);
			 //使用者聊天訂閱 
			 //alert("hello: "+frame);
			 stompClient.subscribe("/userChat/chat"+roomid,function(chat){
				 showChat(JSON.parse(chat.body));
			 }); 
			   
			 //初始化
			 stompClient.subscribe("/app/initChat/"+roomid,function(initData){
				 //alert("初始化聊天室");    
				 console.log(initData);    
				 content=JSON.parse(initData.body);
				 //content=body.document.content;  
				 //alert(content+":"+content.document.content);   
				 content.forEach(function(item){
					 showChat(item);  
				 });
				 sendMessage("1","進入"); 
			 });
		 },function(){ 
			 connect();
		 }); 
	 }
	 
	 //顯示聊天資訊
	 function showChat(message){ 
		  var htmlMsg=decodeURIComponent(message.chatContent);
		    var image="<img src='/images/Pub/User.gif' width='16px' height='16px' align='absmiddle'/>";
			var userMsg=decodeURIComponent(message.deptName)
			+"--"+decodeURIComponent(message.userName)+"   "+decodeURIComponent(message.curTime)+"</font>";
			htmlMsg=userMsg+"<br/>    "+htmlMsg;  
			if(htmlMsg!="") {
				if($("#chatMsg").html()!=""){
					 if(message.isSysMsg=="1")  
						 $("#chatMsg").append("<br/><div style='text-align:center'><font color='gray'>"+htmlMsg+"</div>");
					 else    
			             $("#chatMsg").append("<br/>"+image+"<font color='blue'>"+htmlMsg);   
				}
				else {
					 if(message.isSysMsg=="1")  
						 $("#chatMsg").append("<div style='text-align:center'><font color='gray'>"+htmlMsg+"</div>");
					 else
			             $("#chatMsg").append(image+"<font color='blue'>"+htmlMsg);   
				}
					
				 $("#chatMsg")[0].scrollTop=$("#chatMsg")[0].scrollHeight;    
			} 
	 }
	 
	 function sendMessage(isSysMsg,textMsg){
		 var chatCont=editor.getContent();
		 if(isSysMsg=="1"){
			 chatCont="<font color='gray'>"+textMsg+"聊天室</font>";
		 }
		 stompClient.send("/app/userChat",{},JSON.stringify({
			 'roomid':encodeURIComponent(roomid),
			 'userName':encodeURIComponent(username),
		     'deptName':encodeURIComponent(deptSortName),
		     'chatContent':encodeURIComponent(chatCont),   
			 'isSysMsg':encodeURIComponent(isSysMsg)
		 }))
	 }
	 //---------------------------------------------------------------------------------------------------------------
  	    
</script>  
	</head>                     
	<body style="width:100%;height:100%;margin:0px;overflow:hidden;">     
     	<div id="roomRemark"></div>   
     	<div  style="position:relative;width:99%;height:100%;overflow:auto;display:none;margin-left:5px;"  id="chatMsg"></div>
	</body>  
</html>    
</span>

五、實現效果

建立人tester4進入後，輸入聊天內容後，退出。

聊天室好友tester1進入併發言

下一篇文章將講解在此網頁聊天室上新增視訊聊天功能。

web即時通訊2--基於Spring websocket實現web聊天室

本文使用Spring4和websocket搭建一個web聊天室，框架基於SpringMVC+Spring+Hibernate的Maven專案，後臺使用spring websocket進行訊息轉發和聊天訊息快取。客戶端使用socket.js和stomp.j

基於flask框架，使用websocket實現一對一聊天室功能

info app lan 提示 function _id 數據 sca 響應後端代碼： from flask import Flask,request,render_template from geventwebsocket.handler import WebSock

基於vue,websocket實現線上聊天功能

最近專案中一直在使用vue作為前端框架，可是用到的只有很少一部分的功能，特別是vuex，為了更加深入瞭解vue框架，在工作之餘開發了一款基於vue的線上聊天工具，一下是部分功能效果圖1.登入註冊2.新增好友&國際化3.訊息重發歡迎star

百度t7 課程， websocket 實現簡單聊天室

最簡單的聊天室，我寫了一個小時，寫了10 分鐘，除錯50分鐘因為我是小菜鳥，不過凡事都有過程 index.html <!DOCTYPE html> <html lang="en"> <head> <meta c

Linux下基於UDP協議實現的聊天室專案（附原始碼）

好久沒來更新了，這段時間一直在著手完成這個專案，由於之前沒有接觸過這種稍大型的專案，而且對於C/S架構以及UDP通訊的瞭解也不是很深，所以前面很大的一段時間都被浪費掉了，做了很大無用功。剛開始弄的時候，也是在網上搜了很多資料，找了很多版本，發現大都有

php+websocket實現線上聊天室(二)

上一篇部落格我們完成了服務端的基本結構，這一篇部落格我們就來把它豐富起來以實現聊天室的功能。 1.整理需求 1.進行三人隨機匹配 2.取消匹配 3.傳送訊息 4.離開房間 5.獲取當前線上人數 2.規定訊息格式我們使用json來傳遞

WebSocket實現web即時通信(後端nodejs實現)

tcp ica pri har == bootstra query gif 不容易 WebSocket實現web即時通信一、首先看一下，HTTP、ajax輪詢、long poll和WebSocket的區別：1、HTTP 協議（短連接）：一個 Request 一個 Respo

Spring 學習——基於Spring WebSocket 和STOMP實現簡單的聊天功能

本篇主要講解如何使用Spring websocket 和STOMP搭建一個簡單的聊天功能專案，裡面使用到的技術，如websocket和STOMP等會簡單介紹，不會太深，如果對相關介紹不是很瞭解的，請自行查閱相關知識。本篇的專案主要是一個學習Spring we

Spring+Websocket實現伺服器與Andoird端通訊

本部落格伺服器端內容參考於部落格：http://www.cnblogs.com/3dianpomian/p/5902084.html。寫這篇部落格的原因是在網上查閱了很多資料，關於websocket的介紹和程式碼很多，但是很少有統一給出伺服器端和Andori

用消息隊列實現即時通訊2

.com 查找 str 字段名 mob 獲取 callback 權限認證過期一、準備階段（需求設計）鑒權采用哪種權限認證模式，Cookie由於有域的限制，考慮到以後可能做桌面端，IPhone端等，所以決定采用token進行權限認證，客戶端通過to

spring websocket實現前後端通訊

專案要用websocket實現一個前後端實時通訊的功能，做完之後感觸頗多，寫個部落格回顧下整個歷程，也希望能給後面的同志有點幫助。百度網盤示例原始碼：連結：https://pan.baidu.com/s/1Gi3qRyLO-lTnkVn4MqGIJA 密碼：4ovr我使用

mina和netty多客戶端即時通訊，基於google protobuf傳輸協議實現

基於Java服務端的即時通訊解決方案,與android 客戶端完美結合，同時支援其他語言的移動應用，物聯網，智慧家居，桌面應用，WEB應用以及後臺系統之間的即時消互動，為你解決了長連線各種訊息事件，斷線重連等繁瑣的處理，使用方便易於整合。此開源版本為基礎功能版本，只有訊息推送

Spring Boot入門第二天：一個基於Spring Boot的Web應用，使用了Spring Data JPA和Freemarker。

per pan let mysq 應用 posit ble host thead 今天打算從數據庫中取數據，並展示到視圖中。不多說，先上圖：第一步：添加依賴。打開pom.xml文件，添加必要的依賴，完整代碼如下： <?xml version="1.0" enco

用Websocket實現Web IM（一）

前言：最近領導要求做一版簡單的類似web版微信web IM作為其他產品的過渡，經過跟同事討論後，決定用websocket嘗試做一下（微信使用的是長輪詢保持連線）。首先要解決的是掃碼登入和重連機制問題，雖然實現起來很簡單，但是以防忘記，還是要記錄一下。一、掃碼登陸 1、二維碼

基於Spring Boot實現圖片上傳/加水印一把梭操作

文章共 537字，閱讀大約需要 2分鐘！概述很多網站的圖片為了版權考慮都加有水印，尤其是那些圖片類網站。自己正好最近和圖片打交道比較多，因此就探索了一番基於 Spring Boot這把利器來實現從圖片上傳 → 圖片加水印的一把梭操作！注：本文首發於 M

spring websocket實現

注：需spring4.0及以上版本。步驟： 1、匯入jar包（maven方式）  <dependency> <groupId>org.springframework</groupId>

MySQL多資料來源二(基於spring+aop實現讀寫分離)

一，為什麼要進行讀寫分離呢？　　因為資料庫的“寫操作”操作是比較耗時的（寫上萬條條資料到Mysql的可能要1分鐘分鐘）。但是資料庫的“讀操作”卻比“寫操作”耗時要少的多（從Mysql的讀幾萬條資料條資料可能只要十秒鐘），而我們在開發過程中大多數也是查詢操作比較多。所以讀寫分離解決的是，資料庫的

Spring-WebSocket實現

之前剛寫了java 本身的websocket，再使用spring中的websocket，理解起來就比較容易了； spring 中多出了 WebSocket握手請求的攔截器, 繼承 Interface HandshakeInterceptor; 具體的過程跟 java 沒什麼區別；按照

Spring Security Web 5.1.2 原始碼解析 -- DefaultWebSecurityExpressionHandler 預設Web安全表示式處理器

概述 DefaultWebSecurityExpressionHandler是Spring Security Web用於Web安全表示式處理器(handler)。它會基於一組預設配置，和當時的環境，對指定的Web安全表示式求值。 DefaultWebSecurityExpress

Java高級架構師（一）第13節：Spring MVC實現Web層開發

long true variable creat stp gis delete list java package com.sishuok.architecture1.customermgr.web; import org.springframework.beans.f

web即時通訊2--基於Spring websocket實現web聊天室

相關推薦