125 lines
4.7 KiB
HTML
125 lines
4.7 KiB
HTML
<!DOCTYPE html>
|
|
<html>
|
|
<head>
|
|
<title>聊天测试</title>
|
|
<style>
|
|
body { font-family: Arial, sans-serif; margin: 20px; }
|
|
#messages { border: 1px solid #ccc; height: 300px; overflow-y: auto; padding: 10px; margin-bottom: 10px; }
|
|
#messageInput { width: 300px; padding: 5px; }
|
|
button { padding: 5px 10px; margin: 5px; }
|
|
.status { color: green; }
|
|
.error { color: red; }
|
|
</style>
|
|
</head>
|
|
<body>
|
|
<h1>聊天测试</h1>
|
|
<div id="status">未连接</div>
|
|
<div id="messages"></div>
|
|
<input type="text" id="messageInput" placeholder="输入消息...">
|
|
<button onclick="sendMessage()">发送</button>
|
|
<button onclick="connectWebSocket()">重新连接</button>
|
|
|
|
<script>
|
|
let ws = null;
|
|
let myIp = 'unknown';
|
|
|
|
async function getMyIp() {
|
|
try {
|
|
const response = await fetch('/get_ip');
|
|
const data = await response.json();
|
|
myIp = data.ip;
|
|
console.log('My IP:', myIp);
|
|
document.getElementById('status').innerHTML = `IP: ${myIp} - 准备连接...`;
|
|
} catch (error) {
|
|
console.error('获取IP失败:', error);
|
|
document.getElementById('status').innerHTML = '<span class="error">获取IP失败</span>';
|
|
}
|
|
}
|
|
|
|
function connectWebSocket() {
|
|
if (ws) {
|
|
ws.close();
|
|
}
|
|
|
|
ws = new WebSocket(`ws://${window.location.host}/ws`);
|
|
|
|
ws.onopen = function() {
|
|
console.log('WebSocket连接已建立');
|
|
document.getElementById('status').innerHTML = `<span class="status">已连接 - IP: ${myIp}</span>`;
|
|
};
|
|
|
|
ws.onmessage = function(event) {
|
|
const data = JSON.parse(event.data);
|
|
console.log('收到消息:', data);
|
|
|
|
const messagesDiv = document.getElementById('messages');
|
|
const messageElement = document.createElement('div');
|
|
messageElement.innerHTML = `
|
|
<strong>${data.ip}:</strong> ${data.message}
|
|
<small>(${new Date(data.timestamp).toLocaleTimeString()})</small>
|
|
`;
|
|
messagesDiv.appendChild(messageElement);
|
|
messagesDiv.scrollTop = messagesDiv.scrollHeight;
|
|
};
|
|
|
|
ws.onclose = function() {
|
|
console.log('WebSocket连接已关闭');
|
|
document.getElementById('status').innerHTML = '<span class="error">连接已断开</span>';
|
|
};
|
|
|
|
ws.onerror = function(error) {
|
|
console.error('WebSocket错误:', error);
|
|
document.getElementById('status').innerHTML = '<span class="error">连接错误</span>';
|
|
};
|
|
}
|
|
|
|
function sendMessage() {
|
|
const messageInput = document.getElementById('messageInput');
|
|
const message = messageInput.value.trim();
|
|
|
|
if (!message || !ws || ws.readyState !== WebSocket.OPEN) {
|
|
alert('请输入消息并确保连接正常');
|
|
return;
|
|
}
|
|
|
|
const messageData = {
|
|
message: message,
|
|
timestamp: new Date().getTime(),
|
|
type: 'text'
|
|
};
|
|
|
|
try {
|
|
ws.send(JSON.stringify(messageData));
|
|
messageInput.value = '';
|
|
|
|
// 显示自己的消息
|
|
const messagesDiv = document.getElementById('messages');
|
|
const messageElement = document.createElement('div');
|
|
messageElement.innerHTML = `
|
|
<strong>我 (${myIp}):</strong> ${message}
|
|
<small>(${new Date().toLocaleTimeString()})</small>
|
|
`;
|
|
messageElement.style.color = 'blue';
|
|
messagesDiv.appendChild(messageElement);
|
|
messagesDiv.scrollTop = messagesDiv.scrollHeight;
|
|
} catch (error) {
|
|
console.error('发送消息失败:', error);
|
|
alert('发送消息失败');
|
|
}
|
|
}
|
|
|
|
// 回车键发送消息
|
|
document.getElementById('messageInput').addEventListener('keypress', function(event) {
|
|
if (event.key === 'Enter') {
|
|
sendMessage();
|
|
}
|
|
});
|
|
|
|
// 页面加载时初始化
|
|
window.addEventListener('load', async function() {
|
|
await getMyIp();
|
|
connectWebSocket();
|
|
});
|
|
</script>
|
|
</body>
|
|
</html> |