這篇文章將為大家詳細(xì)講解有關(guān)在SpringBoot中利用Websocket實現(xiàn)一個網(wǎng)頁聊天功能，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。
創(chuàng)新互聯(lián)專注于汝城網(wǎng)站建設(shè)服務(wù)及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗。 熱誠為您提供汝城營銷型網(wǎng)站建設(shè)，汝城網(wǎng)站制作、汝城網(wǎng)頁設(shè)計、汝城網(wǎng)站官網(wǎng)定制、小程序定制開發(fā)服務(wù)，打造汝城網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供汝城網(wǎng)站排名全網(wǎng)營銷落地服務(wù)。
導(dǎo)入websocket的包。
通過使用SpringBoot導(dǎo)入包的時候，我們可以發(fā)現(xiàn)，很多包都是以 spring-boot-starter 開頭的，對于我這種強迫癥 ，簡直是福音
org.springframework.boot spring-boot-starter-websocket
配置websocket
服務(wù)端
首先新建一個WebSocketConfig的類，添加 @Component 注解 注入一個bean
重慶分公司
重慶分公司
@Component
public class WebSocketConfig {
@Bean
public ServerEndpointExporter serverEndpointExporter() {
return new ServerEndpointExporter();
}
}新建一個service，本來覺得是新建一個控制器，但是我覺得這也不是控制器，但是也不太是service。最后還是選擇新建一個servece。這里你如果有更好的想法可以按照你的來。
這個service里面有4個方法，這些方法很簡單，通過名稱就可以看出是什么意思。
@Component
@ServerEndpoint("/webSocket")
@Slf4j
public class WebSocket {
private Session session;
private static CopyOnWriteArraySet webSockets = new CopyOnWriteArraySet<>();
private MessageVO messageVO = new MessageVO();
@OnOpen
public void onOpen(Session session) {
this.session = session;
webSockets.add(this);
messageVO.setType(1);
messageVO.setUserNum(webSockets.size());
messageVO.setMessage("有新的連接");
ObjectMapper mapper = new ObjectMapper();
String Json = "";
try {
Json = mapper.writeValueAsString(messageVO);
} catch (Exception ex) {
log.error(ex.getMessage());
}
this.sendMessage(Json);
log.info("【websocket消息】有新的連接, 總數(shù):{}", webSockets.size());
}
@OnClose
public void onClose() {
webSockets.remove(this);
messageVO.setType(2);
messageVO.setUserNum(webSockets.size());
messageVO.setMessage("有用戶離開");
ObjectMapper mapper = new ObjectMapper();
String Json = "";
try {
Json = mapper.writeValueAsString(messageVO);
} catch (Exception ex) {
log.error(ex.getMessage());
}
this.sendMessage(Json);
log.info("【websocket消息】連接斷開, 總數(shù):{}", webSockets.size());
}
@OnMessage
public void onMessage(String message) {
messageVO.setType(3);
messageVO.setUserNum(webSockets.size());
messageVO.setMessage(message);
ObjectMapper mapper = new ObjectMapper();
String Json = "";
try {
Json = mapper.writeValueAsString(messageVO);
} catch (Exception ex) {
log.error(ex.getMessage());
}
this.sendMessage(Json);
log.info("【websocket消息】收到客戶端發(fā)來的消息:{}", message);
}
public void sendMessage(String message) {
for (WebSocket webSocket : webSockets) {
log.info("【websocket消息】廣播消息, message={}", message);
try {
webSocket.session.getBasicRemote().sendText(message);
} catch (Exception e) {
e.printStackTrace();
}
}
}
} 客戶端
客戶端也就是我們的html，我用的是原生html5的websocket ,不需要其他的js。直接在html中寫js就可以
關(guān)于在SpringBoot中利用Websocket實現(xiàn)一個網(wǎng)頁聊天功能就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。
