當(dāng)前位置：首頁 > 前端技术 > HTML >内容正文

HTML

futurejava前台_web前端页面与后端Java的数据交互

發(fā)布時(shí)間：2025/3/20 HTML 26 豆豆

生活随笔收集整理的這篇文章主要介紹了 futurejava前台_web前端页面与后端Java的数据交互小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

java代碼：

package com.lpc.main;

import java.io.IOException;

import java.util.Set;

import java.util.concurrent.CopyOnWriteArraySet;

import java.util.concurrent.atomic.AtomicInteger;

import javax.websocket.OnClose;

import javax.websocket.OnError;

import javax.websocket.OnMessage;

import javax.websocket.OnOpen;

import javax.websocket.Session;

import javax.websocket.server.ServerEndpoint;

/**

* ?* 類名稱:Server.java 類描述:簡單的聊天室作者:wantao 時(shí) 間:2018年03月08日 23:11:48

@ServerEndpoint(value = "/chat")

public class Test {

private static final String GUEST_PREFIX = "用戶";

/**

* 一個(gè)提供原子操作的Integer的類。在Java語言中，++i和i++操作并不是線程安全的，

* 在使用的時(shí)候，不可避免的會(huì)用到synchronized關(guān)鍵字。而AtomicInteger則通過一種線程安全的加減操作接口。

private static final AtomicInteger connectionIds = new AtomicInteger(0);

// 存放用戶的websocket

private static final Set connections = new CopyOnWriteArraySet<>();

private final String nickname;

private Session session;

public Test() {

nickname = GUEST_PREFIX + connectionIds.getAndIncrement();

}

/**

* 創(chuàng)建連接時(shí)間調(diào)用的方法

* @param session

@OnOpen

public void start(Session session) {

this.session = session;

connections.add(this);

String message = String.format("* %s %s", nickname, "加入聊天室");

// 上線通知

broadcast(message);

try {

// 系統(tǒng)問候語

SendHello(this.nickname);

// 返回在線用戶

onlineList();

} catch (IOException e) {

e.printStackTrace();

}

/**

* 鏈接關(guān)閉時(shí)調(diào)用方法

@OnClose

public void end() {

connections.remove(this);

String message = String.format("* %s %s", nickname, "退出聊天室");

broadcast(message);

}

/**

* 傳輸信息過程中調(diào)用方法

* @param message

@OnMessage

public void incoming(String message) {

// Never trust the client

// TODO: 過濾輸入的內(nèi)容

String m = String.format("* %s %s", nickname, message);

if (m.contains("to")) {

// 點(diǎn)對點(diǎn)發(fā)送

broadcastOneToOne(m, nickname);

} else {

// 群發(fā)

broadcast(m);

}

/**

* 發(fā)生錯(cuò)誤是調(diào)用方法

* @param t

* @throws Throwable

@OnError

public void onError(Throwable t) throws Throwable {

System.out.println("錯(cuò)誤: " + t.toString());

}

/**

* 消息廣播通過connections，對所有其他用戶推送信息的方法

* @param msg

private static void broadcast(String msg) {

for (Test client : connections) {

try {

synchronized (client) {

client.session.getBasicRemote().sendText(msg);

}

} catch (IOException e) {

System.out.println("錯(cuò)誤:向客戶端發(fā)送消息失敗");

connections.remove(client);

try {

client.session.close();

} catch (IOException e1) {

e1.printStackTrace();

}

String message = String.format("* %s %s", client.nickname,

"退出聊天室");

broadcast(message);

}

/**

* 點(diǎn)對點(diǎn)發(fā)送消息通過connections，對所有其他用戶推送信息的方法

* @param msg

private static void broadcastOneToOne(String msg, String nickName) {

String[] arr = msg.split("to");

for (Test client : connections) {

try {

if (arr[1].equals(client.nickname)

|| nickName.equals(client.nickname)) {

synchronized (client) {

client.session.getBasicRemote().sendText(arr[0]);

}

} catch (IOException e) {

System.out.println("錯(cuò)誤:向客戶端發(fā)送消息失敗");

connections.remove(client);

try {

client.session.close();

} catch (IOException e1) {

e1.printStackTrace();

}

String message = String.format("* %s %s", client.nickname,

"退出聊天室");

broadcast(message);

}

// 系統(tǒng)問候語

private static void SendHello(String nickName) throws IOException {

String m = String.format("* %s %s", nickName, "你好");

for (Test client : connections) {

if (client.nickname.equals(nickName)) {

client.session.getBasicRemote().sendText(m);

}

// 在線用戶

private static void onlineList() throws IOException {

String online = "";

for (Test client : connections) {

if (online.equals("")) {

online = client.nickname;

} else {

online += "," + client.nickname;

}

String m = String.format("* %s %s", "當(dāng)前在線用戶", online);

for (Test client : connections) {

client.session.getBasicRemote().sendText(m);

}

jsp文件

String path = request.getContextPath();

String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";

websocket

input#chat {

width: 410px

}

#console-container {

width: 400px;

}

#console {

border: 1px solid #CCCCCC;

border-right-color: #999999;

border-bottom-color: #999999;

height: 170px;

overflow-y: scroll;

padding: 5px;

width: 100%;

}

#console p {

padding: 0;

margin: 0;

}

"use strict";

var Chat = {};

Chat.socket = null;

Chat.connect = (function(host) {

if ('WebSocket' in window) {

Chat.socket = new WebSocket(host);

} else if ('MozWebSocket' in window) {

Chat.socket = new MozWebSocket(host);

} else {

Console.log('Error: 瀏覽器不支持WebSocket');

return;

}

Chat.socket.onopen = function () {

Console.log('Info: WebSocket鏈接已打開');

document.getElementById('chat').onkeydown = function(event) {

if (event.keyCode == 13) {

Chat.sendMessage();

}

};

Chat.socket.onclose = function () {

document.getElementById('chat').onkeydown = null;

Console.log('Info: webcocket關(guān)閉.');

};

Chat.socket.onmessage = function (message) {

Console.log(message.data);

};

});

Chat.initialize = function() {

if (window.location.protocol == 'http:') {

Chat.connect('ws://' + window.location.host + '/WebSocket/chat');

} else {

Chat.connect('wss://' + window.location.host + '/WebSocket/chat');

}

};

Chat.sendMessage = (function() {

var message = document.getElementById('chat').value;

if (message != '') {

Chat.socket.send(message);

document.getElementById('chat').value = '';

}

});

var Console = {};

Console.log = (function(message) {

var console = document.getElementById('console');

var p = document.createElement('p');

p.style.wordWrap = 'break-word';

p.innerHTML = message;

console.appendChild(p);

while (console.childNodes.length > 25) {

console.removeChild(console.firstChild);

}

console.scrollTop = console.scrollHeight;

});

Chat.initialize();

document.addEventListener("DOMContentLoaded", function() {

// Remove elements with "noscript" class -

is not allowed in XHTML

var noscripts = document.getElementsByClassName("noscript");

for (var i = 0; i < noscripts.length; i++) {

noscripts[i].parentNode.removeChild(noscripts[i]);

}

}, false);

Seems your browser doesn't support Javascript! Websockets rely on Javascript being enabled. Please enable

Javascript and reload this page!

注意：輸入? 消息to用戶名? ?發(fā)送給指定用戶? ?比如：? 你好to用戶1

輸入? ?消息? ? ?直接發(fā)送給全體用戶

運(yùn)行后提示

Info: webcocket關(guān)閉.

eclipse控制臺(tái)輸出信息：