分类技术下的文章 - 枉自朝朝暮暮

2025-05-12

Nginx+Lua脚本控制负载均衡 Nginx+Lua脚本控制负载均衡有时候会根据不同客户需求，提供特有的私有环境，但是接口入口都是统一的情况下，如何将用户请求转发到特定的机器上呢？如果可以根据用户请求的参数进行判断，然后nginx转根据对应参数转发到对应服务器就可以啦。Nginx本身是可以获取到用户请求参数的，就像这样：比如我要获取https://api.example.com?id=testlocation / { echo "appId: $arg_id"; }通过上述配置是可以获取到Get请求中Url所携带的参数，但是Post请求是无法获取的，但是现在大部分api都是Post请求。而且为了更灵活的判断用户参数，再进行相应转发，我们就需要用到Lua脚本啦。Lua脚本配置Lua 是一个由标准 C 语言开发的、开源的、可扩展的、轻量级的、弱类型的、解释型脚本语言。OpenResty集成了Lua脚本，直接上如何配置。1.设置缓存数据的脚本 cache.lua-- 获取内存数据 local ups_cache = nginx.shared.ups_cache function set_cache(key, value) local success, err = my_cache:set(key, calue) if not success then ngx.log(ngx.ERR, "failed to set cache: ", err) return nil end return true end function get_cache(key) return ups_cache:get(key) end function get_ups() ngx.req.read_body() -- 确保读取整个请求体 local body_data = ngx.req.get_body_data() if not body_data then ngx.status = ngx.HTTP_BAD_REQUEST ngx.say("Failed to read request body") return nil end local json_data = cjson.decode(body_data) if not json_data then ngx.status = ngx.HTTP_BAD_REQUEST ngx.say("Invalid JSON data in request body") return nil end local appId = json_data.appId return get_cache(appId) end return { set_cache = set_cache; get_cache = get_cache; get_ups = get_ups; }2.根据缓存数据获取ups，（get_ups.lua）local cacheUtils= require "cache" local upsValue = cacheUtils.get_ups(); if upsValue then ngx.var.my_ups = upsValue endNginx配置1. 指定内存区域缓存配置数据http { lua_shared_dict ups_cache 128k; }2.通过接口传输配置数据到Nginxserver { listen 80; server_name api.xxx.com; location /updateCache { content_by_lua_block { -- 引入json工具 local cjson = require "cjson" -- 引入cache.lua local cache = require "cache" -- 读取请求体中的 JSON 数据 ngx.req.read_body() -- 确保读取整个请求体 local json_data = ngx.req.get_body_data() if not json_data then ngx.status = ngx.HTTP_BAD_REQUEST ngx.say("Failed to read request body") return end -- 解析 JSON 数据 local data, err = cjson.decode(json_data) if not data then ngx.status = ngx.HTTP_BAD_REQUEST ngx.say("Invalid JSON data") return end local key = data.key local value = cjson.encode(data.value) -- 将 Value 编码为 JSON 字符串存入缓存 -- 将数据存入缓存 if cache.set_cache(key, value) then ngx.status = ngx.HTTP_OK ngx.say("Data cached successfully") else ngx.status = ngx.HTTP_INTERNAL_SERVER_ERROR ngx.say("Failed to cache data") end } } }3.业务接口配置upstream ups_normal { server 192.168.1.1:8080; } upstream ups_test { server 192.168.1.2:8080; } server { #省略 ... location /v1 { proxy_set_header Host $host; proxy_set_header X-Real-IP $remote_addr; proxy_buffering off; #设置默认转发的upstream set $my_ups 'ups_normal'; access_by_lua_file "/opt/get_ups.lua"; proxy_pass http://$my_ups } } 这种方式可以很灵活的通过业务端进行负载均衡的控制，如果觉得Nginx的共享内存不稳定，容易造成配置数据的丢失，还可以对数据的缓存做进一步的处理，比如将数据缓存到redis中，再持久化到数据库中。定时将数据同步至Nginx缓存中，避免redis或者数据库对于接口性能的影响。

2025年05月12日
176 阅读
0 评论
0 点赞

2025-05-11

2025年05月11日
140 阅读
0 评论
0 点赞

2024-01-02

Gitlab修改用户密码 Gitlab修改用户密码打开rails控制台，并在控制台中执行2-5的步骤。sudo gitlab-rails console根据用户名或者用户ID找到user；根据用户名user = User.find_by_username 'yourusername'根据用户IDuser = User.find(123)根据邮箱地址：user = User.find_by(email: 'user@example.com')重设密码new_password = 'examplepassword' #or new_password = ::User.random_password user_password = new_password user.password_confirmation = new_password邮件通知user.send_only_admin_changed_your_password_notification!保存并退出user.save! exit如果还是不行，则重启下gitlabgitlab-ctl restart

2024年01月02日
128 阅读
0 评论
0 点赞

2023-08-01

2023年08月01日
166 阅读
0 评论
0 点赞

2023-05-11

【学习笔记】ES新特性 ES新特性1.概念ES全程EcmaScript，是脚本语言的规范，Javascript是EcmaScript的一种实现，所以ES新特性就是指JavaScript的新特性。1.1.编年史年份版本名称正式名称主要新增特性重要事件/说明1997ECMAScript 1ES1首个标准版本，定义了 JavaScript 的基础语法和功能。由 ECMA 国际组织发布，对应 ECMA-262 标准第一版。1998ECMAScript 2ES2小幅更新，与 ISO/IEC 16262 标准同步。修正规范格式，无重大功能新增。1999ECMAScript 3ES3正则表达式、try/catch 异常处理、instanceof、typeof、for...in 等。成为 JavaScript 的通行标准，广泛支持，奠定了现代 JavaScript 的基础。2007ECMAScript 4未发布模块、类、静态类型、泛型等激进特性（草案）。草案因争议被终止，部分功能被拆分到后续版本。2008ECMAScript 3.1ES5（重命名）基于 ES3 的小改进（如 JSON 支持、严格模式 use strict）。原计划为 ES4 的子集，后更名为 ES5。2009ECMAScript 5ES5严格模式、JSON 支持、新对象方法（如 Object.create）、数组迭代方法等。正式发布，成为主流浏览器支持的版本。2011ECMAScript 5.1ES5.1与 ISO/IEC 16262 国际标准同步，修正 ES5 的部分缺陷。成为 ISO 国际标准（ISO/IEC 16262:2011）。2013ECMAScript 6 草案ES6（草案冻结）类、模块、箭头函数、解构赋值、Promise、模板字符串等。草案冻结，不再添加新功能，进入讨论期。2015ECMAScript 2015ES6 / ES2015类、模块、箭头函数、解构赋值、let/const、Promise、模板字符串等。正式发布，首次按年份命名（ES6 后改称 ES2015），是 JavaScript 的重大升级版本。2016ECMAScript 2016ES7 / ES2016指数运算符（**）、Array.prototype.includes()。首个年度版本，新增特性较少但保持持续更新。2017ECMAScript 2017ES8 / ES2017Object.values()/keys()、async/await、for...of 与 let/const 支持。引入 async/await 简化异步编程。2018ECMAScript 2018ES9 / ES2018Promise.prototype.finally()、async 函数的 iterable 支持、Rest/Spread 运算符。增强异步编程和语法糖。2019ECMAScript 2019ES10 / ES2019Array.prototype.flat()/flatMap()、Object.fromEntries()、String.trimStart()/trimEnd()。更多数组和字符串方法的优化。2020ECMAScript 2020ES11 / ES2020Nullish 合并运算符（??）、动态导入（import()）、BigInt、Promise.allSettled()。引入 BigInt 处理大整数，增强异步控制。2021ECMAScript 2021ES12 / ES2021Logical Assignment Operators（&&=、` 2.ES62.1.迭代器通过实现 Symbol.iterator 方法，可以自定义可迭代对象。const customIterable = { data: [10, 20, 30], [Symbol.iterator]() { let index = 0; const data = this.data; return { next() { if (index < data.length) { return { value: data[index++], done: false }; } else { return { done: true }; } } }; } }; for (const num of customIterable) { console.log(num); // 输出 10, 20, 30 }2.2.生成器生成器是一种特殊的函数，使用 function* 定义，通过 yield 关键字暂停和恢复执行，自动实现迭代器协议。yield 会暂停函数执行，返回一个值给外部迭代器，下次调用 next() 时从暂停处继续执行。function* simpleGenerator() { yield 1; yield 2; yield 3; } const gen = simpleGenerator(); console.log(gen.next()); // { value: 1, done: false } console.log(gen.next()); // { value: 2, done: false } console.log(gen.return(100)); // 提前终止，{ value: 100, done: true }function* infiniteSequence() { let i = 0; while (true) { yield i++; } } const gen = infiniteSequence(); console.log(gen.next().value); // 0 console.log(gen.next().value); // 1 // 无限继续...function* fibonacci() { let a = 0, b = 1; while (true) { yield a; [a, b] = [b, a + b]; } } const fib = fibonacci(); console.log(fib.next().value); // 0 console.log(fib.next().value); // 1 console.log(fib.next().value); // 1 console.log(fib.next().value); // 22.3.PromisePromise 是一个表示异步操作最终完成或失败的对象，代表了某个未来才会知道结果的事件（如网络请求、文件读写等）。用途：处理异步操作（如网络请求、文件读取），避免回调地狱（Callback Hell）。状态：pending（进行中）：初始状态，既未成功也未失败。fulfilled（已成功）：操作成功完成，调用 resolve 方法。rejected（已失败）：操作失败，调用 reject 方法。特点：状态一旦改变（如从 pending 到 fulfilled 或 rejected），就不可逆，且后续操作只能通过 then 或 catch 处理结果。2.3.1.创建Promise通过 new Promise(executor) 构造函数创建：const myPromise = new Promise((resolve, reject) => { // 异步操作（如网络请求） const success = true; if (success) { resolve("操作成功"); // 成功时调用 resolve } else { reject("操作失败"); // 失败时调用 reject } });2.3.2.基础使用then：处理成功状态，接受两个参数（成功回调和失败回调）：myPromise .then((value) => { console.log(value); // 输出 "操作成功" }, (error) => { console.error(error); });catch：专门处理失败状态，等同于.then(null, rejectCallback)：myPromise .then((value) => console.log(value)) .catch((error) => console.error(error));finally 方法：无论成功或失败，都会执行 finally 回调（ES2018 引入）：myPromise .then(data => console.log(data)) .catch(error => console.error(error)) .finally(() => console.log("操作完成"));示例代码：// 模拟异步请求 function fetchData() { return new Promise((resolve, reject) => { setTimeout(() => { Math.random() > 0.5 ? resolve("数据加载成功") : reject("网络错误"); }, 1000); }); } // 使用示例 fetchData() .then(data => console.log(data)) .catch(error => console.error(error)) .finally(() => console.log("请求结束"));2.3.3.应用场景网络请求：fetch("https://api.example.com/data") .then(response => response.json()) .then(data => console.log(data)) .catch(error => console.error("请求失败", error));文件读写：const readFile = (path) => new Promise((resolve, reject) => { fs.readFile(path, (err, data) => { if (err) reject(err); else resolve(data); }); });延时操作：const delay = (ms) => new Promise(resolve => setTimeout(resolve, ms)); delay(1000).then(() => console.log("1秒后执行"));2.3.4.高级用法(1) Promise.all()并行执行多个 Promise，全部成功后返回结果数组：const promise1 = Promise.resolve(1); const promise2 = new Promise((resolve) => setTimeout(() => resolve(2), 1000)); const promise3 = Promise.reject("错误"); Promise.all([promise1, promise2]) .then((results) => console.log(results)); // [1, 2] Promise.all([promise1, promise2, promise3]) .catch((error) => console.error(error)); // "错误"(2) Promise.race()返回最先完成的 Promise 结果或错误：const fastPromise = Promise.resolve("快"); const slowPromise = new Promise((resolve) => setTimeout(() => resolve("慢"), 2000)); Promise.race([fastPromise, slowPromise]) .then((result) => console.log(result)); // "快"(3) Promise.allSettled()（ES2020）等待所有 Promise 完成（无论成功或失败）：const promises = [ Promise.resolve("成功"), Promise.reject("失败"), ]; Promise.allSettled(promises).then((results) => { results.forEach((result) => { if (result.status === "fulfilled") { console.log("成功:", result.value); } else { console.log("失败:", result.reason); } }); });2.4.模块化将一个大的程序文件，拆分成许多小的文件，然后将小文件组合起来。2.4.1.语法export用于暴露规定模块的对外接口import用于引入外部的模块接口示例//util.js export function isNull(){} export function isNotNull(){} //main.js import * from "./utils.js" import {isNUll, isNotNull} from "./utils.js" import {isNUll} from "./utils.js"html中编写：<script type="module"> import语句 </script2.4.2.暴露方式分别暴露export let a = 1; export function isNull(){} export function isNotNull(){}统一暴露let a = ; function isNUll(){} export { a, isNull }默认暴露export default { name: "angsan" play: function (){ console.log("play basketball") } }2.4.3.引入方式通用方式：import * as m1 from "./a.js"解构赋值方式：import {name as nickname, play} from "./a.js"、import {default as m1} from "./a.js"简单形式（针对默认暴露）：import m1 from "./a.js"ES83.1.async&awaitasync: 声明一个异步函数，自动将函数返回值包装为 Promise。该函数返回一个 Promise 对象。如果函数返回一个普通值（如 return 1），则自动包装为 Promise.resolve(值)。如果函数抛出异常（如 throw new Error），则自动包装为 Promise.reject(错误)。async function fetchData() { // 异步操作（返回 Promise） return "数据"; } // 调用 async 函数 const result = fetchData(); // 返回 Promise result.then(data => console.log(data)); // "数据"await：暂停异步函数的执行，等待 Promise 完成并返回结果。暂停当前 async 函数的执行，直到等待的 Promise 完成（fulfilled 或 rejected）。不会阻塞主线程，其他代码可以继续执行。只能在 async 函数内部使用async function getData() { try { const response = await fetch("https://api.example.com/data"); // 等待 Promise const data = await response.json(); // 等待下一个 Promise console.log(data); } catch (error) { console.error("错误:", error); } } getData();执行流程示例async function asyncFunc() { console.log("Start"); const result = await slowPromise(); // 暂停此处，等待Promise完成 console.log("Result:", result); console.log("End"); } asyncFunc(); console.log("Main code continues..."); // 立即执行，不阻塞主线程 function slowPromise() { return new Promise(resolve => setTimeout(() => resolve("Done"), 1000)); }应用示例：//定义一个返回Promise对象的异步函数 function sendAJAX(url){ return new Promise(()=>{ const x = new XMLHttpRequest(); x.open('GET', url); x.send(); x.onreadystatechange = function () { if(x.readyState === 4){ if(x.status >= 200 && x.status < 300){ resolve(x.response) }else{ reject(x.status) } } } }); } sendAJAX("1").then(value=>console.log(value)); async function send(){ try{ let result = await sendAJAX(""); console.log(result); }catch(error){ } } send(); ES11可选链操作符function readConfig(config){ const dbHost = config?.db?.host; console.log(dbHost);//10.0.0.1 } main({ db:{ host:'10.0.0.1', username:'root' }, cache:{ host:'10.0.0.1', username:'admin' } }); 动态import//方法内部 import('./').then((module)=>{ module.hello(); });globalThis全局对象，

2023年05月11日
163 阅读
0 评论
0 点赞