資源簡介
基于spring websocket實現廣播及點對點推送功能Demo。
開發環境：IntelliJ IDEA 2016.3.4
運行環境：jre1.8.0_131
服務器：Tomcat 8.5
測試步驟：
1.配置好環境，主要是maven和tomcat；
2.編譯并運行，使用不同的瀏覽器分別進行連接；
3.將不同瀏覽器“控制臺”或者“console”監聽的/user/**/message中**作為ID填入輸入框；
4.點擊“Send”，發現只有ID匹配的瀏覽器才會接收到消息，到此點對點測試完成；
5.在任意瀏覽器中打開新的瀏覽頁，訪問localhost:8080/send，在所有連接的客戶端均受到消息，到此廣播測試完成。
代碼片段和文件信息
package?com.controller;
import?com.model.Greeting;
import?com.model.HelloMessage;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.messaging.handler.annotation.MessageMapping;
import?org.springframework.messaging.handler.annotation.SendTo;
import?org.springframework.messaging.simp.SimpMessageSendingOperations;
import?org.springframework.messaging.simp.annotation.SendToUser;
import?org.springframework.messaging.simp.annotation.SubscribeMapping;
import?org.springframework.web.bind.annotation.RequestMapping;
import?org.springframework.web.bind.annotation.RequestMethod;
import?org.springframework.web.bind.annotation.RestController;
import?java.util.HashMap;
import?java.util.Map;
import?java.util.Random;
/**
?*?Created?by?haoyuyang?on?2016/11/25.
?*/
@RestController
public?class?GreetingController?{
????@Autowired
????private?SimpMessageSendingOperations?simpMessageSendingOperations;
????/**
?????*?表示服務端可以接收客戶端通過主題“/app/hello”發送過來的消息，客戶端需要在主題“/topic/hello“上監聽并接收服務端發回的消息
?????*/
????@MessageMapping（“/hello“）?//“/hello“為WebSocketConfig類中registerStompEndpoints（）方法配置的
????@SendTo（“/topic/greetings“）
????public?Greeting?greeting（HelloMessage?message）?{
????????System.out.println（“connected?successfully....“）;
????????String?name?=?message.getName（）;
????????simpMessageSendingOperations.convertAndSendToUser（name“/message“new?Greeting（“P2P:?“+name））;
????????return?new?Greeting（“Hello“+name）;
????}
????@SubscribeMapping（“/macro“）
????@SendTo（“/topic/greetings“）
????public?Greeting?hand（）{
????????System.out.println（“connected?successfully....“）;
????????simpMessageSendingOperations.convertAndSend（“/topic/greetings“new?Greeting（“macro“））;
????????return?new?Greeting（“I?macro“）;
????}
????/**
?????*?這里用的是@SendToUser，這就是發送給單一客戶端的標志。本例中，
?????*?客戶端接收一對一消息的主題應該是“/user/”?+?用戶Id?+?“/message”?這里的用戶id可以是一個普通的字符串，只要每個用戶端都使用自己的id并且服務端知道每個用戶的id就行。
?????*?@return
?????*/
????@MessageMapping（“/message“）
????@SendToUser（“/message“）
????public?Greeting?handleSubscribe（）?{
????????System.out.println（“this?is?the?@SubscribeMapping（‘/marco‘）“）;
????????return?new?Greeting（“I?am?a?msg?from?SubscribeMapping（‘/macro‘）.“）;
????}
????@RequestMapping（value?=?“/getId“method?=?RequestMethod.POST）
????public?Mapject>?getId（）?{
????????Mapject>?map?=?new?HashMapject>（）;
????????map.put（“id“String.valueOf（new?Random（）.nextInt（100）））;
????????return?map;
????}
????/**
?????*?測試對指定用戶發送消息方法
?????*?@return
?????*/
????@RequestMapping（value?=?“/send“?method?=?RequestMethod.GET）
????public?Greeting?send（）?{
????????simpMessageSendingOperations.convertAndSend（“/topic/feed“?new?Greeting（“feed“））;
????????simpMessageSendingOperations.convertAndSend（“/topic/greetings“?new?Greeting（“greetings“））;
????????return?new?Greeting（“TTTTTTTT“）;
????}
}
?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2017-07-17?09:22??HelloWeb\
?????目錄???????????0??2017-07-14?11:32??HelloWeb\.idea\
?????目錄???????????0??2017-07-13?16:37??HelloWeb\.idea\artifacts\
?????文件????????2370??2017-07-13?16:37??HelloWeb\.idea\artifacts\HelloWeb_war_exploded.xm
?????文件?????????628??2017-07-12?15:00??HelloWeb\.idea\compiler.xm
?????目錄???????????0??2017-07-12?15:01??HelloWeb\.idea\libraries\
?????文件?????????538??2017-07-12?15:00??HelloWeb\.idea\libraries\Maven__aopalliance_aopalliance_1_0.xm
?????文件?????????668??2017-07-12?15:00??HelloWeb\.idea\libraries\Maven__com_fasterxm
?????文件?????????619??2017-07-12?15:00??HelloWeb\.idea\libraries\Maven__com_fasterxm
?????文件?????????647??2017-07-12?15:00??HelloWeb\.idea\libraries\Maven__com_fasterxm
?????文件?????????582??2017-07-12?15:01??HelloWeb\.idea\libraries\Maven__commons_logging_commons_logging_1_2.xm
?????文件?????????602??2017-07-12?15:01??HelloWeb\.idea\libraries\Maven__javax_servlet_javax_servlet_api_3_1_0.xm
?????文件?????????633??2017-07-12?15:01??HelloWeb\.idea\libraries\Maven__org_springfr
?????文件?????????647??2017-07-12?15:01??HelloWeb\.idea\libraries\Maven__org_springfr
?????文件?????????661??2017-07-12?15:01??HelloWeb\.idea\libraries\Maven__org_springfr
?????文件?????????717??2017-07-12?15:01??HelloWeb\.idea\libraries\Maven__org_springfr
?????文件?????????640??2017-07-12?15:01??HelloWeb\.idea\libraries\Maven__org_springfr
?????文件?????????682??2017-07-12?15:01??HelloWeb\.idea\libraries\Maven__org_springfr
?????文件?????????675??2017-07-12?15:01??HelloWeb\.idea\libraries\Maven__org_springfr
?????文件?????????633??2017-07-12?15:01??HelloWeb\.idea\libraries\Maven__org_springfr
?????文件?????????654??2017-07-12?15:01??HelloWeb\.idea\libraries\Maven__org_springfr
?????文件?????????675??2017-07-12?15:01??HelloWeb\.idea\libraries\Maven__org_springfr
?????文件?????????454??2017-07-12?14:20??HelloWeb\.idea\misc.xm
?????文件?????????256??2017-07-12?14:17??HelloWeb\.idea\modules.xm
?????文件???????67704??2017-07-14?11:32??HelloWeb\.idea\workspace.xm
?????文件????????3180??2017-07-13?16:54??HelloWeb\HelloWeb.iml
?????文件?????????443??2017-07-17?09:31??HelloWeb\README.txt
?????目錄???????????0??2017-07-12?15:01??HelloWeb\out\
?????目錄???????????0??2017-07-12?15:01??HelloWeb\out\artifacts\
?????目錄???????????0??2017-07-14?09:38??HelloWeb\out\artifacts\HelloWeb_war_exploded\
?????目錄???????????0??2017-07-12?15:01??HelloWeb\out\artifacts\HelloWeb_war_exploded\me
............此處省略82個文件信息
評論
共有 條評論
川公網安備 51152502000135號