先说点无关的,最近忙于工作没有更新博客,今天休息顺便把golang websocket研究了一下,挺好玩的,写了一个聊天室,分享给大家.
websocket包 : code.google.com/p/go.net/websocket
文档 : http://go.pkgdoc.org/code.google.com/p/go.net/websocket
首先安装websocket包
go get code.google.com/p/go.net/websocket
下来就是聊天室代码了,呵呵
golang websocket 聊天室
package main
import (
"fmt"
"io"
"bufio"
"net/http"
"code.google.com/p/go.net/websocket"
"container/list"
)
var connid int
var conns *list.List
func ChatroomServer(ws *websocket.Conn) {
defer ws.Close()
connid++
id := connid
fmt.Printf("connection id: %d\n", id)
item := conns.PushBack(ws)
defer conns.Remove(item)
name := fmt.Sprintf("user%d", id)
SendMessage(nil, fmt.Sprintf("welcome %s join\n", name))
r := bufio.NewReader(ws)
for {
data, err := r.ReadBytes('\n')
if err != nil {
fmt.Printf("disconnected id: %d\n", id)
SendMessage(item, fmt.Sprintf("%s offline\n", name))
break
}
fmt.Printf("%s: %s", name, data)
SendMessage(item, fmt.Sprintf("%s\t> %s", name, data))
}
}
func SendMessage(self *list.Element, data string) {
// for _, item := range conns {
for item := conns.Front(); item != nil; item = item.Next() {
ws, ok := item.Value.(*websocket.Conn)
if !ok {
panic("item not *websocket.Conn")
}
if item == self {
continue
}
io.WriteString(ws, data)
}
}
// 网页客户端
func Client(w http.ResponseWriter, r *http.Request) {
html := `<!doctype html>
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<title>golang websocket chatroom</title>
<script src="http://ajax.googleapis.com/ajax/libs/jquery/1.7.2/jquery.min.js"></script>
<script>
var ws = new WebSocket("ws://127.0.0.1:6611/chatroom");
ws.onopen = function(e){
console.log("onopen");
console.dir(e);
};
ws.onmessage = function(e){
console.log("onmessage");
console.dir(e);
$('#log').append('<p>'+e.data+'<p>');
$('#log').get(0).scrollTop = $('#log').get(0).scrollHeight;
};
ws.onclose = function(e){
console.log("onclose");
console.dir(e);
};
ws.onerror = function(e){
console.log("onerror");
console.dir(e);
};
$(function(){
$('#msgform').submit(function(){
ws.send($('#msg').val()+"\n");
$('#log').append('<p style="color:red;">My > '+$('#msg').val()+'<p>');
$('#log').get(0).scrollTop = $('#log').get(0).scrollHeight;
$('#msg').val('');
return false;
});
});
</script>
</head>
<body>
<div id="log" style="height: 300px;overflow-y: scroll;border: 1px solid #CCC;">
</div>
<div>
<form id="msgform">
<input type="text" id="msg" size="60" />
</form>
</div>
</body>
</html>`
io.WriteString(w, html)
}
func main() {
fmt.Printf(`Welcome chatroom server!
author: dotcoo zhao
url: http://www.dotcoo.com/golang-websocket-chatroom
`)
connid = 0
conns = list.New()
http.Handle("/chatroom", websocket.Handler(ChatroomServer));
http.HandleFunc("/", Client);
err := http.ListenAndServe(":6611", nil);
if err != nil {
panic("ListenAndServe: " + err.Error())
}
}
简陋了些,但是基本功能都有了.
golang websocket 客户端
package main
import (
"fmt"
"bufio"
"io"
"os"
"code.google.com/p/go.net/websocket"
)
func Command(ws *websocket.Conn) {
r := bufio.NewReader(os.Stdin)
w := bufio.NewWriter(ws)
for {
data, err := r.ReadBytes('\n')
if err != nil {
panic(err)
}
_, err = w.Write(data)
if err != nil {
panic(err)
}
w.Flush()
fmt.Printf("My\t> ")
}
}
func main() {
fmt.Printf(`Welcome chatroom!
author: dotcoo zhao
url: http://www.dotcoo.com/golang-websocket-chatroom
`)
origin := "http://127.0.0.1:6611/"
url := "ws://127.0.0.1:6611/chatroom"
ws, err := websocket.Dial(url, "", origin)
if err != nil {
panic(err)
}
defer ws.Close()
r := bufio.NewReader(ws)
//w := bufio.NewWriter(os.Stdout)
go Command(ws)
for {
data, err := r.ReadBytes('\n')
if err == io.EOF {
fmt.Printf("disconnected\n")
os.Exit(0)
}
if err != nil {
panic(err)
}
fmt.Printf("\r%sMy\t> ", data)
}
}
相关推荐
### Golang 基于 WebSocket 实现的简易聊天室程序详解 #### 一、引言 随着互联网技术的发展，实时通信的需求越来越广泛。WebSocket 作为一种在单个 TCP 连接上进行全双工通信的协议，能够实现实时的数据交换。本篇...
Go语言实现简单的聊天室使用示例操作下列代码cd ./srcgo get github.com/gorilla/websocketgo run main.go然后浏览器打开 localhost:8000鸣谢说明代码基于ezynda3的go-chat修改并完善，由于代码被我改的面目全非，...
这对于实时应用如聊天室、游戏或股票报价等是非常理想的，因为它消除了HTTP请求-响应模式的延迟。 2. **Go语言**：这个聊天应用是用Go语言编写的，Go（也称为Golang）是由Google开发的一种静态类型的编程语言，以其...
重点：所有项目均附赠详尽的SQL文件，这一细节的处理，让我们的项目相比其他博主的作品，严谨性提升了不止一个量级！更重要的是，所有项目源码均经过我亲自的严格测试与验证，确保能够无障碍地正常运行。 1.项目适用场景：本项目特别适用于计算机领域的毕业设计课题、课程作业等场合。对于计算机科学与技术等相关专业的学生而言，这些项目无疑是一个绝佳的选择，既能满足学术要求，又能锻炼实际操作能力。 2.超值福利：所有定价为9.9元的项目，均包含完整的SQL文件。如需远程部署可随时联系我，我将竭诚为您提供满意的服务。在此，也想对一直以来支持我的朋友们表示由衷的感谢，你们的支持是我不断前行的动力！ 3.求关注：如果觉得我的项目对你有帮助，请别忘了点个关注哦！你的支持对我意义重大，也是我持续分享优质资源的动力源泉。再次感谢大家的支持与厚爱！ 4.资源详情：https://blog.csdn.net/2301_78888169/article/details/144929660 更多关于项目的详细信息与精彩内容，请访问我的CSDN博客！
2024年AI代码平台及产品发展简报-V11
蓝桥杯算法学习冲刺（主要以题目为主）
QPSK调制解调技术研究与FPGA实现：详细实验文档的探索与实践,基于FPGA实现的QPSK调制解调技术：实验文档详细解读与验证,QPSK调制解调 FPGA设计，有详细实验文档 ,QPSK调制解调; FPGA设计; 详细实验文档,基于QPSK调制的FPGA设计与实验文档
PID、ADRC和MPC轨迹跟踪控制器在Matlab 2018与Carsim 8中的Simulink仿真研究,PID、ADRC与MPC轨迹跟踪控制器在Matlab 2018与Carsim 8中的仿真研究,PID, ADRC和MPC轨迹跟踪控制器Simulink仿真模型。 MPC用于跟踪轨迹 ADRC用于跟踪理想横摆角 PID用于跟踪轨迹 轨迹工况有双移线，避障轨迹，正弦轨迹多种 matlab版本为2018，carsim版本为8 ,PID; ADRC; MPC; 轨迹跟踪控制器; Simulink仿真模型; 双移线; 避障轨迹; 正弦轨迹; MATLAB 2018; CarSim 8,基于Simulink的PID、ADRC与MPC轨迹跟踪控制器仿真模型研究
重点：所有项目均附赠详尽的SQL文件，这一细节的处理，让我们的项目相比其他博主的作品，严谨性提升了不止一个量级！更重要的是，所有项目源码均经过我亲自的严格测试与验证，确保能够无障碍地正常运行。 1.项目适用场景：本项目特别适用于计算机领域的毕业设计课题、课程作业等场合。对于计算机科学与技术等相关专业的学生而言，这些项目无疑是一个绝佳的选择，既能满足学术要求，又能锻炼实际操作能力。 2.超值福利：所有定价为9.9元的项目，均包含完整的SQL文件。如需远程部署可随时联系我，我将竭诚为您提供满意的服务。在此，也想对一直以来支持我的朋友们表示由衷的感谢，你们的支持是我不断前行的动力！ 3.求关注：如果觉得我的项目对你有帮助，请别忘了点个关注哦！你的支持对我意义重大，也是我持续分享优质资源的动力源泉。再次感谢大家的支持与厚爱！ 4.资源详情：https://blog.csdn.net/2301_78888169/article/details/144486173 更多关于项目的详细信息与精彩内容，请访问我的CSDN博客！
内容概要：本文档详细介绍了一个利用Matlab实现Transformer-Adaboost结合的时间序列预测项目实例。项目涵盖Transformer架构的时间序列特征提取与建模，Adaboost集成方法用于增强预测性能，以及详细的模型设计思路、训练、评估过程和最终的GUI可视化。整个项目强调数据预处理、窗口化操作、模型训练及其优化（包括正则化、早停等手段）、模型融合策略和技术部署，如GPU加速等，并展示了通过多个评估指标衡量预测效果。此外，还提出了未来的改进建议和发展方向，涵盖了多层次集成学习、智能决策支持、自动化超参数调整等多个方面。最后部分阐述了在金融预测、销售数据预测等领域中的广泛应用可能性。 适合人群：具有一定编程经验的研发人员，尤其对时间序列预测感兴趣的研究者和技术从业者。 使用场景及目标：该项目适用于需要进行高质量时间序列预测的企业或机构，比如金融机构、能源供应商和服务商、电子商务公司。目标包括但不限于金融市场的波动性预测、电力负荷预估和库存管理。该系统可以部署到各类平台，如Linux服务器集群或云计算环境，为用户提供实时准确的预测服务，并支持扩展以满足更高频率的数据吞吐量需求。 其他说明：此文档不仅包含了丰富的理论分析，还有大量实用的操作指南，从项目构思到具体的代码片段都有详细记录，使用户能够轻松复制并改进这一时间序列预测方案。文中提供的完整代码和详细的注释有助于加速学习进程，并激发更多创新想法。
液滴穿越障碍：从文献到案例的复现研究,液滴破裂与障碍物穿越：文献复现案例研究,液滴生成并通过障碍物破裂。 该案例是文献复现，文献与案例一起。 ,液滴生成; 障碍物破裂; 文献复现; 案例研究,液滴破裂：障碍挑战的文献复现案例
蓝桥杯算法学习冲刺（主要以题目为主）
蓝桥杯算法学习冲刺（主要以题目为主）
基于最小递归二乘法的MPC自适应轨迹跟踪控制优化 针对轮胎刚度时变特性提升模型精度与鲁棒性，仿真验证满足车辆低速高精度跟踪与高速稳定性提升。,基于变预测时域MPC自适应轨迹跟踪控制与轮胎侧偏刚度优化提升模型精度和鲁棒性,基于变预测时域的MPC自适应轨迹跟踪控制，针对轮胎刚度时变的特点造成控制模型精度降低，基于最小递归二乘法（RLS）估算的轮胎侧偏刚度，提升了模型的控制精度和鲁棒性，通过carsim与simulink联合仿真结果发现，改进后的轨迹跟踪控制器既满足了车辆低速行驶下的轨 迹跟踪精度，也一定程度上克服了高速下车辆容易失去稳定性的问题。 有详细的lunwen分析说明和资料，以及本人的，仿真包运行。 ,基于变预测时域的MPC; 自适应轨迹跟踪控制; 轮胎刚度时变; 控制模型精度降低; 最小递归二乘法(RLS)估算; 模型控制精度和鲁棒性提升; carsim与simulink联合仿真; 轨迹跟踪控制器; 车辆稳定性。,基于变预测时域MPC的轮胎刚度自适应轨迹跟踪控制策略研究
GMSK调制解调技术研究：基于FPGA设计与实验详解,GMSK调制解调技术详解：基于FPGA设计的实验文档与实践应用,GMSK调制解调 FPGA设计，有详细实验文档 ,GMSK调制解调; FPGA设计; 详细实验文档; 实验结果分析,GMSK调制解调技术：FPGA设计与实验详解
# 基于Arduino和Python的Cansat卫星系统 ## 项目简介 本项目是一个Cansat卫星系统，旨在设计和实现一个小型卫星模型，通过火箭发射至1公里高空，并使用地面站接收其传输的数据。项目涉及Arduino编程、Python数据处理和可视化。 ## 主要特性和功能 1. 硬件组件 使用Arduino Nano作为Cansat的微控制器。 搭载BMP 280温度和压力传感器、ATGM336H GPS模块、LoRa通信模块等。 地面站使用Arduino Uno和LoRa通信模块接收数据。 2. 数据处理 使用Python进行数据处理和可视化，包括数据清洗、计算风速、绘制温度、压力、风速和海拔随时间变化的图表等。 3. 通信与控制 通过LoRa模块实现Cansat与地面站之间的数据传输。 提供实时监视和记录数据的脚本。 ## 安装和使用步骤 ### 1. 硬件准备
U9300C 龙尚4G模块安装后模块才能正常使用，win7 win10驱动程序，支持USB转接板。
# 基于Arduino平台的物联网温湿度监控系统 ## 项目简介 这是一个基于Arduino平台的物联网温湿度监控项目，旨在通过简单的硬件设备实现环境数据的实时监测与远程管理。该项目适用于智能家居、农业种植等领域。 ## 项目的主要特性和功能 1. 温湿度数据采集通过Arduino板连接温湿度传感器，实时采集环境数据。 2. 数据传输将采集到的数据通过无线网络模块发送到服务器或远程终端。 3. 数据可视化可在电脑或移动设备端展示实时的温湿度数据。 4. 报警功能当温湿度数据超过预设阈值时，自动触发报警通知。 ## 安装使用步骤 前提假设用户已经下载了本项目的源码文件。以下是简单明了的安装使用步骤 1. 环境准备安装Arduino开发环境，配置必要的硬件接口。 2. 硬件连接将Arduino板与温湿度传感器、无线网络模块连接。 3. 代码上传将本项目提供的Arduino代码上传至Arduino板。
基于需求响应与清洁能源接入的配电网重构优化：综合成本与混合整数凸规划模型分析（matlab实现）,基于需求响应与清洁能源接入的配电网重构算法研究：网损与成本优化的仿真分析,高比例清洁能源接入下计及需求响应的配电网重构（matlab代码） 该程序复现《高比例清洁能源接入下计及需求响应的配电网重构》，以考虑网损成本、弃风弃光成本和开关操作惩罚成本的综合成本最小为目标，针对配电网重构模型的非凸性，引入中间变量并对其进行二阶锥松弛，构建混合整数凸规划模型，采用改进的 IEEE33 节点配电网进行算例仿真，分析了需求响应措施和清洁能源渗透率对配电网重构结果的影响。 该程序复现效果和出图较好（详见程序结果部分），注释清楚，方便学习 ,高比例清洁能源; 需求响应; 配电网重构; 二阶锥松弛; 综合成本最小化; MATLAB代码; IEEE33节点配电网; 复现效果; 出图; 注释清楚。,Matlab代码复现：高比例清洁能源接入下的配电网重构模型与需求响应分析
# 基于C++的RapidJSON库测试项目 ## 项目简介 本项目是一个基于C++的RapidJSON库测试项目，主要用于测试RapidJSON库的功能正确性、性能以及稳定性。RapidJSON是一个高效的C++ JSON解析生成库，广泛应用于各种场景。本项目通过编写一系列的单元测试，覆盖了RapidJSON库的主要功能点，包括JSON解析、生成、内存管理、编码转换等，以确保RapidJSON库在各种情况下都能正确、稳定地工作。 ## 项目的主要特性和功能 1. 单元测试框架使用Google Test测试框架进行单元测试，确保测试的可靠性和可扩展性。 2. 全面测试覆盖覆盖了RapidJSON库的主要功能点，包括JSON解析、生成、内存管理、编码转换等，以及针对各种输入数据的测试。 3. 性能测试通过性能基准测试，评估RapidJSON库在处理不同规模和类型的JSON数据时的性能表现。