openresty聊天室的helloworld

haoningabc

浏览: 1496264 次
性别:
来自: 北京

最近访客更多访客>>

zfyq124

bartontang

dlzdy

cnnlush0605

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

lua
websocket
nginx

redis nginx lua openresty

openresty的websocket + redis的subscribe

参考
https://blog.csdn.net/orangleliu/article/details/50898014
利用redis的subscribe
参考http://www.runoob.com/redis/pub-sub-subscribe.html

安装redis
brew install redis
安装openresty：

brew install openssl  

  
./configure --prefix=/usr/local/openresty --with-openssl=/usr/local/Cellar/openssl/1.0.2o_1  
make  
make install

openssl还是有问题 shared等
参考
https://blog.csdn.net/csdncqmyg/article/details/73835354

bundle/nginx-x-x-x(版本号)/auto/lib/openssl/conf
把.openssl删掉，只删这个单词

nginx调用的lua模块
ws_resdis_json.lua

local server = require "resty.websocket.server"
local redis = require "resty.redis"

local cjson = require "cjson"

--local channel_name = "chat"
local msg_id = 0
local wb, err = server:new{
  timeout = 10000,
  max_payload_len = 65535
}
if not wb then
  ngx.log(ngx.ERR, "failed to new websocket: ", err)
  return ngx.exit(444)
end

function creatChanel(channel_name)
	push = function()
	    -- --create redis
	    local red = redis:new()
	    red:set_timeout(5000) -- 1 sec
	    local ok, err = red:connect("127.0.0.1", 6379)
	    if not ok then
	        ngx.log(ngx.ERR, "failed to connect redis: ", err)
	        wb:send_close()
	        return
	    end

	    --sub
	    local res, err = red:subscribe(channel_name)
	    if not res then
	        ngx.log(ngx.ERR, "failed to sub redis: ", err)
	        wb:send_close()
	        return
	    end

	    -- loop : read from redis
	    while true do
	        local res, err = red:read_reply()
	        if res then
	            local item = res[3]
	            local bytes, err = wb:send_text(tostring(msg_id).." "..item)
	            if not bytes then
	                -- better error handling
	                ngx.log(ngx.ERR, "failed to send text: ", err)
	                return ngx.exit(444)
	            end
	            msg_id = msg_id + 1
	        end
	    end
	end


	co = ngx.thread.spawn(push)
end

--main loop
while true do
    local data, typ, err = wb:recv_frame()

    if wb.fatal then
        ngx.log(ngx.ERR, "failed to receive frame: ", err)
        return ngx.exit(444)
    end

    if not data then
        local bytes, err = wb:send_ping()
        if not bytes then
          ngx.log(ngx.ERR, "failed to send ping: ", err)
          return ngx.exit(444)
        end
        ngx.log(ngx.ERR, "send ping: ", data)
    elseif typ == "close" then
        break
    elseif typ == "ping" then
        local bytes, err = wb:send_pong()
        if not bytes then
            ngx.log(ngx.ERR, "failed to send pong: ", err)
            return ngx.exit(444)
        end
    elseif typ == "pong" then
        ngx.log(ngx.ERR, "client ponged")
    elseif typ == "text" then
		--local json_str = '{"name": "Bruce.Lin", "age": 25}'
		local json_str = data
   		local json = cjson.decode(json_str)

    	local channel_name = json["name"]
    	creatChanel(channel_name)

        --send to redis
        local red2 = redis:new()
        red2:set_timeout(1000) -- 1 sec
        local ok, err = red2:connect("127.0.0.1", 6379)
        if not ok then
            ngx.log(ngx.ERR, "failed to connect redis: ", err)
            break
        end
        local res, err = red2:publish(channel_name, data)
        if not res then
            ngx.log(ngx.ERR, "failed to publish redis: ", err)
        end
    end
end

wb:send_close()
ngx.thread.wait(co)

nginx的配置文件
加入

	location = /sredis {
    	    content_by_lua_file conf/lua/ws_redis_json.lua;
    	}

客户端代码

<!DOCTYPE HTML>
<html>

<head>
    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0, user-scalable=no">
    <script type="text/javascript">
    var ws = null;

    function WebSocketConn() {
        if (ws != null && ws.readyState == 1) {
            log("已经在线");
            return
        }

        if ("WebSocket" in window) {
            // Let us open a web socket
            ws = new WebSocket("ws://localhost/sredis");

            ws.onopen = function() {
                log('成功进入聊天室');
            };

            ws.onmessage = function(event) {
                log(event.data)
            };

            ws.onclose = function() {
                // websocket is closed.
                log("已经和服务器断开");
            };

            ws.onerror = function(event) {
                console.log("error " + event.data);
            };
        } else {
            // The browser doesn't support WebSocket
            alert("WebSocket NOT supported by your Browser!");
        }
    }

    function SendMsg() {
        if (ws != null && ws.readyState == 1) {
            var msg = document.getElementById('msgtext').value;
            ws.send(msg);
        } else {
            log('请先进入聊天室');
        }
    }

    function WebSocketClose() {
        if (ws != null && ws.readyState == 1) {
            ws.close();
            log("发送断开服务器请求");
        } else {
            log("当前没有连接服务器")
        }
    }

    function log(text) {
        var li = document.createElement('li');
        li.appendChild(document.createTextNode(text));
        document.getElementById('log').appendChild(li);
        return false;
    }
    </script>
</head>

<body>
	{"name": "Bruce.Lin", "age": 25}
    <div id="sse">
        <a href="javascript:WebSocketConn()">进入聊天室</a> &nbsp;
        <a href="javascript:WebSocketClose()">离开聊天室</a>
        <br>
        <br>
        <input id="msgtext" type="text">
        <br>
        <a href="javascript:SendMsg()">发送信息</a>
        <br>
        <ol id="log"></ol>
    </div>
</body>

</html>

测试，进入聊天室
{"name": "Bruce.Lin", "age": 25}

name就是发给聊天室的name

分享到：

nginx push_upstream模块的websocket | openresty websocket

2018-04-22 19:25
浏览 881
评论(0)
分类:互联网
查看更多

发表评论

您还没有登录,请您登录后再发表评论

相关推荐

毕业设计物联网实战项目基于Eclipse Theia开源框架开发的物联网在线编程IDE.zip: 【项目资源】：物联网项目适用于从基础到高级的各种项目，特别是在性能要求较高的场景中，比如操作系统开发、嵌入式编程和底层系统编程。如果您是初学者，可以从简单的控制台程序开始练习；如果是进阶开发者，可以尝试涉及硬件或网络的项目。【项目质量】：所有源码都经过严格测试，可以直接运行。功能在确认正常工作后才上传。【适用人群】：适用于希望学习不同技术领域的小白或进阶学习者。可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。【附加价值】：项目具有较高的学习借鉴价值，也可直接拿来修改复刻。对于有一定基础或热衷于研究的人来说，可以在这些基础代码上进行修改和扩展，实现其他功能。【沟通交流】：有任何使用上的问题，欢迎随时与博主沟通，博主会及时解答。鼓励下载和使用，并欢迎大家互相学习，共同进步。 # 注意 1. 本资源仅用于开源学习和技术交流。不可商用等，一切后果由使用者承担。 2. 部分字体以及插图等来自网络，若是侵权请联系删除。

Android毕设实战项目基于Android的医院挂号系统.zip: 【项目资源】：适用于从基础到高级的各种项目，特别是在性能要求较高的场景中，比如操作系统开发、嵌入式编程和底层系统编程。如果您是初学者，可以从简单的控制台程序开始练习；如果是进阶开发者，可以尝试涉及硬件或网络的项目。【项目质量】：所有源码都经过严格测试，可以直接运行。功能在确认正常工作后才上传。【适用人群】：适用于希望学习不同技术领域的小白或进阶学习者。可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。【附加价值】：项目具有较高的学习借鉴价值，也可直接拿来修改复刻。对于有一定基础或热衷于研究的人来说，可以在这些基础代码上进行修改和扩展，实现其他功能。【沟通交流】：有任何使用上的问题，欢迎随时与博主沟通，博主会及时解答。鼓励下载和使用，并欢迎大家互相学习，共同进步。 # 注意 1. 本资源仅用于开源学习和技术交流。不可商用等，一切后果由使用者承担。 2. 部分字体以及插图等来自网络，若是侵权请联系删除。

(源码)基于Python的KMeans和EM算法结合图像分割项目.zip: # 基于Python的KMeans和EM算法结合图像分割项目 ## 项目简介本项目结合KMeans聚类和EM（期望最大化）算法，实现对马赛克图像的精准分割。通过Gabor滤波器提取图像的多维特征，并利用KMeans进行初步聚类，随后使用EM算法优化聚类结果，最终生成高质量的分割图像。 ## 项目的主要特性和功能 1. 图像导入和预处理: 支持导入马赛克图像，并进行灰度化、滤波等预处理操作。 2. 特征提取: 使用Gabor滤波器提取图像的多维特征向量。 3. 聚类分析: 使用KMeans算法对图像进行初步聚类。利用KMeans的聚类中心初始化EM算法，进一步优化聚类结果。 4. 图像生成和比较: 生成分割后的图像，并与原始图像进行比较，评估分割效果。 5. 数值比较: 通过计算特征向量之间的余弦相似度，量化分割效果的提升。 ## 安装使用步骤 ### 假设用户已经下载了项目的源码文件 1. 环境准备:

HCIP第一次作业：静态路由综合实验: HCIP第一次作业：静态路由综合实验

毕设单片机实战项目基于stm32、esp8266和Android的智能家居系统-设备端.zip: 【项目资源】：单片机项目适用于从基础到高级的各种项目，特别是在性能要求较高的场景中，比如操作系统开发、嵌入式编程和底层系统编程。如果您是初学者，可以从简单的控制台程序开始练习；如果是进阶开发者，可以尝试涉及硬件或网络的项目。【项目质量】：所有源码都经过严格测试，可以直接运行。功能在确认正常工作后才上传。【适用人群】：适用于希望学习不同技术领域的小白或进阶学习者。可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。【附加价值】：项目具有较高的学习借鉴价值，也可直接拿来修改复刻。对于有一定基础或热衷于研究的人来说，可以在这些基础代码上进行修改和扩展，实现其他功能。【沟通交流】：有任何使用上的问题，欢迎随时与博主沟通，博主会及时解答。鼓励下载和使用，并欢迎大家互相学习，共同进步。 # 注意 1. 本资源仅用于开源学习和技术交流。不可商用等，一切后果由使用者承担。 2. 部分字体以及插图等来自网络，若是侵权请联系删除。

统计学基于Python的Johnson-SU分布参数计算与优化：数据拟合及弹性网络参数优化方法实现（复现论文或解答问题，含详细可运行代码及解释）: 内容概要：本文详细介绍了Johnson-SU分布的参数计算与优化过程，涵盖位置参数γ、形状参数δ、尺度参数ξ和伸缩参数λ的计算方法，并实现了相应的Python代码。文中首先导入必要的库并设置随机种子以确保结果的可复现性。接着，分别定义了四个参数的计算函数，其中位置参数γ通过加权平均值计算，形状参数δ基于局部均值和标准差的比值，尺度参数ξ结合峰度和绝对偏差，伸缩参数λ依据偏态系数。此外，还实现了Johnson-SU分布的概率密度函数（PDF），并使用负对数似然函数作为目标函数，采用L-BFGS-B算法进行参数优化。最后，通过弹性网络的贝叶斯优化展示了另一种参数优化方法。; 适合人群：具有Python编程基础，对统计学和机器学习有一定了解的研究人员或工程师。; 使用场景及目标：①需要对复杂数据分布进行建模和拟合的场景；②希望通过优化算法提升模型性能的研究项目；③学习如何实现和应用先进的统计分布及优化技术。; 阅读建议：由于涉及较多数学公式和编程实现，建议读者在阅读时结合相关数学知识，同时动手实践代码，以便更好地理解和掌握Johnson-SU分布及其优化方法。

TSP问题的3种智能优化方法求解（研究生课程《智能优化算法》结课大作业）.zip: TSP问题的3种智能优化方法求解（研究生课程《智能优化算法》结课大作业）.zip

毕业设计物联网实战项目基于Rtthread和MQTT搭建的物联网网关.zip: 【项目资源】：物联网项目适用于从基础到高级的各种项目，特别是在性能要求较高的场景中，比如操作系统开发、嵌入式编程和底层系统编程。如果您是初学者，可以从简单的控制台程序开始练习；如果是进阶开发者，可以尝试涉及硬件或网络的项目。【项目质量】：所有源码都经过严格测试，可以直接运行。功能在确认正常工作后才上传。【适用人群】：适用于希望学习不同技术领域的小白或进阶学习者。可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。【附加价值】：项目具有较高的学习借鉴价值，也可直接拿来修改复刻。对于有一定基础或热衷于研究的人来说，可以在这些基础代码上进行修改和扩展，实现其他功能。【沟通交流】：有任何使用上的问题，欢迎随时与博主沟通，博主会及时解答。鼓励下载和使用，并欢迎大家互相学习，共同进步。 # 注意 1. 本资源仅用于开源学习和技术交流。不可商用等，一切后果由使用者承担。 2. 部分字体以及插图等来自网络，若是侵权请联系删除。

基于STM32F103C8T6的温湿度传感器(HAL库版)，通过串口向电脑端反馈数据（附通过ESP8266-01s模块连接WIFI上传云平台的资料代码-固件库版本）.zip: 【项目资源】：单片机项目适用于从基础到高级的各种项目，特别是在性能要求较高的场景中，比如操作系统开发、嵌入式编程和底层系统编程。如果您是初学者，可以从简单的控制台程序开始练习；如果是进阶开发者，可以尝试涉及硬件或网络的项目。【项目质量】：所有源码都经过严格测试，可以直接运行。功能在确认正常工作后才上传。【适用人群】：适用于希望学习不同技术领域的小白或进阶学习者。可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。【附加价值】：项目具有较高的学习借鉴价值，也可直接拿来修改复刻。对于有一定基础或热衷于研究的人来说，可以在这些基础代码上进行修改和扩展，实现其他功能。【沟通交流】：有任何使用上的问题，欢迎随时与博主沟通，博主会及时解答。鼓励下载和使用，并欢迎大家互相学习，共同进步。 # 注意 1. 本资源仅用于开源学习和技术交流。不可商用等，一切后果由使用者承担。 2. 部分字体以及插图等来自网络，若是侵权请联系删除。

自动发布Java项目（Tomcat）Shell脚本: 自动发布Java项目（Tomcat）Shell脚本

(源码)基于webpack和Vue的前端项目构建方案.zip: # 基于webpack和Vue的前端项目构建方案 ## 项目简介本项目是基于webpack和Vue构建的前端项目方案，借助webpack强大的打包能力以及Vue的开发特性，可用于快速搭建现代化的前端应用。项目不仅完成了基本的webpack与Vue的集成配置，还在构建速度优化和代码规范性方面做了诸多配置。 ## 项目的主要特性和功能 1. 打包功能运用webpack进行模块打包，支持将scss转换为css，借助babel实现语法转换。 2. Vue开发支持集成Vue框架，能使用Vue单文件组件的开发模式。 3. 构建优化采用threadloader实现多进程打包，cacheloader缓存资源，极大提高构建速度开启热更新功能，开发更高效。 4. 错误处理与优化提供不同环境下的错误映射配置，便于定位错误利用webpackbundleanalyzer分析打包体积。

Hands-On Large Language Models - Jay Alammar 袋鼠书《动手学大语言模型》: Hands-On Large Language Models - Jay Alammar 袋鼠书《动手学大语言模型》PDF

《基于YOLOv8的舞蹈动作分析系统》（包含源码、完整数据集、可视化界面、部署教程）简单部署即可运行。功能完善、操作简单，适合毕设或课程设计.zip: 资源内项目源码是来自个人的毕业设计，代码都测试ok，包含源码、数据集、可视化页面和部署说明，可产生核心指标曲线图、混淆矩阵、F1分数曲线、精确率-召回率曲线、验证集预测结果、标签分布图。都是运行成功后才上传资源，毕设答辩评审绝对信服的保底85分以上，放心下载使用，拿来就能用。包含源码、数据集、可视化页面和部署说明一站式服务，拿来就能用的绝对好资源！！！项目备注 1、该资源内项目代码都经过测试运行成功，功能ok的情况下才上传的，请放心下载使用！ 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习，也适合小白学习进阶，当然也可作为毕设项目、课程设计、大作业、项目初期立项演示等。 3、如果基础还行，也可在此代码基础上进行修改，以实现其他功能，也可用于毕设、课设、作业等。下载后请首先打开README.txt文件，仅供学习参考, 切勿用于商业用途。

(源码)基于Arduino Feather M0和Raspberry Pi的传感器数据采集与监控系统.zip: # 基于Arduino Feather M0和Raspberry Pi的传感器数据采集与监控系统 ## 项目简介本项目是一个基于Arduino Feather M0和Raspberry Pi的传感器数据采集与监控系统。系统通过Arduino Feather M0采集传感器数据，并通过WiFi将数据传输到Raspberry Pi。Raspberry Pi运行BalenaOS，集成了MySQL、PHP、NGINX、Apache和Grafana等工具，用于数据的存储、处理和可视化。项目适用于环境监测、物联网设备监控等场景。 ## 项目的主要特性和功能 1. 传感器数据采集使用Arduino Feather M0和AM2315传感器采集温度和湿度数据。 2. WiFi数据传输Arduino Feather M0通过WiFi将采集到的数据传输到Raspberry Pi。

《基于YOLOv8的音响设备识别系统》（包含源码、完整数据集、可视化界面、部署教程）简单部署即可运行。功能完善、操作简单，适合毕设或课程设计.zip: 资源内项目源码是来自个人的毕业设计，代码都测试ok，包含源码、数据集、可视化页面和部署说明，可产生核心指标曲线图、混淆矩阵、F1分数曲线、精确率-召回率曲线、验证集预测结果、标签分布图。都是运行成功后才上传资源，毕设答辩评审绝对信服的保底85分以上，放心下载使用，拿来就能用。包含源码、数据集、可视化页面和部署说明一站式服务，拿来就能用的绝对好资源！！！项目备注 1、该资源内项目代码都经过测试运行成功，功能ok的情况下才上传的，请放心下载使用！ 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习，也适合小白学习进阶，当然也可作为毕设项目、课程设计、大作业、项目初期立项演示等。 3、如果基础还行，也可在此代码基础上进行修改，以实现其他功能，也可用于毕设、课设、作业等。下载后请首先打开README.txt文件，仅供学习参考, 切勿用于商业用途。

Android毕设实战项目这是一个android 图书管理系统.zip: 【项目资源】：适用于从基础到高级的各种项目，特别是在性能要求较高的场景中，比如操作系统开发、嵌入式编程和底层系统编程。如果您是初学者，可以从简单的控制台程序开始练习；如果是进阶开发者，可以尝试涉及硬件或网络的项目。【项目质量】：所有源码都经过严格测试，可以直接运行。功能在确认正常工作后才上传。【适用人群】：适用于希望学习不同技术领域的小白或进阶学习者。可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。【附加价值】：项目具有较高的学习借鉴价值，也可直接拿来修改复刻。对于有一定基础或热衷于研究的人来说，可以在这些基础代码上进行修改和扩展，实现其他功能。【沟通交流】：有任何使用上的问题，欢迎随时与博主沟通，博主会及时解答。鼓励下载和使用，并欢迎大家互相学习，共同进步。 # 注意 1. 本资源仅用于开源学习和技术交流。不可商用等，一切后果由使用者承担。 2. 部分字体以及插图等来自网络，若是侵权请联系删除。

毕业设计物联网实战项目基于智龙2.0开发板和窄带物联网模块BC95。操作系统为RTT2.1。.zip: 【项目资源】：物联网项目适用于从基础到高级的各种项目，特别是在性能要求较高的场景中，比如操作系统开发、嵌入式编程和底层系统编程。如果您是初学者，可以从简单的控制台程序开始练习；如果是进阶开发者，可以尝试涉及硬件或网络的项目。【项目质量】：所有源码都经过严格测试，可以直接运行。功能在确认正常工作后才上传。【适用人群】：适用于希望学习不同技术领域的小白或进阶学习者。可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。【附加价值】：项目具有较高的学习借鉴价值，也可直接拿来修改复刻。对于有一定基础或热衷于研究的人来说，可以在这些基础代码上进行修改和扩展，实现其他功能。【沟通交流】：有任何使用上的问题，欢迎随时与博主沟通，博主会及时解答。鼓励下载和使用，并欢迎大家互相学习，共同进步。 # 注意 1. 本资源仅用于开源学习和技术交流。不可商用等，一切后果由使用者承担。 2. 部分字体以及插图等来自网络，若是侵权请联系删除。

(源码)基于Arduino的WiFi按钮项目.zip: # 基于Arduino的WiFi按钮项目 ## 一、项目简介本项目是一个基于ESP8266芯片的Arduino项目，主要实现WiFi连接、电压检测、LED灯控制以及向服务器发送POST请求等功能。通过简单的按钮操作，可以实现与服务器通信并获取相关信息，同时能检测电池电压并提示用户。 ## 二、项目的主要特性和功能 1. WiFi连接项目能够自动连接到指定的WiFi网络。 2. 电压检测通过ADC（模数转换器）检测电池电压，并在电压低于阈值时发出警告。 3. LED灯控制通过控制LED灯的亮灭来提示用户不同的状态信息（如连接成功、电压低等）。 4. 服务器通信项目可以向指定的服务器发送POST请求并处理返回的HTTP响应。 ## 三、安装使用步骤 1. 环境准备确保已安装Arduino IDE和ESP8266插件。 2. 下载源码下载项目的源码文件并解压。 3. 打开项目在Arduino IDE中打开解压后的main.cpp文件。

scipy-0.10.1-cp26-cp26mu-manylinux1_x86_64.whl: 该资源为scipy-0.10.1-cp26-cp26mu-manylinux1_x86_64.whl，欢迎下载使用哦！

计算机毕业设计；计算机毕设；Java毕业设计；小程序毕业设计: 计算机毕业设计；计算机毕设；Java毕业设计；小程序毕业设计；企业、旅游、党建、学校、人事、酒店、民宿、预约、考试、外卖、点餐、外贸、宠物、图书、销售、商城、就业、助农、仓储、交易、美食、博客、婚庆、二手、养老、医院、医疗、药品、招聘、考勤、宿舍、物流、租赁、公益等

最近访客 更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论

openresty聊天室的helloworld

评论

发表评论

相关推荐

websocket直播

ios的safari使用自制ca证书测试webrtc

nginx push_upstream模块的websocket

openresty websocket

nginx代理wss和https

nginx模块开发(三)upstream模块

nginx模块开发(二) 使用gdb-dashboard调试

nginx模块开发(一)

nginx带进度条的上传超大文件

nginx rewrite替代apache rewrite

websocket和tap使用select关联

ffmpeg+nginx 的直播(2,直播摄像头和麦克风)

ffmpeg+nginx 的直播(1,直播播放的视频文件)

websocket传传图片

websocket相关调研 总结帖

autobahn的helloworld

ios websocket server端

ios客户端websocket的helloworld

websocket,使用tomcat7转发

nginx执行流程

最近访客更多访客>>

websocket相关调研总结帖