【iPro案例分享】利用iPro实现Lotus Notes应用负载
  

江威 3797

{{ttag.title}}
本帖最后由 江威 于 2017-3-31 17:19 编辑

1、背景介绍
    Lotus Notes可以集成很多应用,在很多企业都作为办公OA系统,具有一定的普遍性,对于大型企业来说,办公OA系统会直接影响到职员的办公效率,可以部署多台Lotus Notes系统通过负载均衡的方式对外提供服务,一方面提高服务器的响应速度,另一方面可以提高扩展性,而对终端用户来说不需要修改服务器地址。

2、协议分析
    Lotus Notes是IBM开发的一套办公软件,在访问其服务器时,数据包中会携带要访问的服务器IP地址,同时在数据包的头两个字节中表明此数据包的长度,服务器在收到客户端的数据包时会校验此数据包的合法性,具体可以见下图(第一张图中标记了服务器地址;第二张图中标记了数据包的长度,此图为7c):


3、解决方案
通过AD对Lotus Notes进行负载,需要对外修改为统一的VIP地址,那么必然导致服务器检查服务器IP地址这一部分不通过,因此,需要通过iPro脚本将其VIP地址修改为当前调度的节点IP地址,修改数据包之后可能造成数据包长度变化,需要一并修改,源码如下:
  1. --[[
  2.         Lotus Notes 应用负载,首个连接有协商,共2个数据包需要替换VIP
  3. --]]

  4. local rs = nil
  5. local packet = 1

  6. --调试
  7. function dbg(str)
  8.         LOG.log(LOG.DEBUG, str)
  9. end

  10. event CLIENT_ACCEPT
  11. {
  12.         dbg("CLIENT_ACCEPT")
  13.                
  14.         rs = pool("srv")
  15.        
  16.         if rs
  17.         then
  18.             dbg("sched ok, rs "..rs.ip..":"..rs.port)
  19.         else
  20.             dbg("ERROR: sched failed")
  21.             TCP.close()
  22.         end
  23.        
  24.         TCP.collect()
  25. }

  26. --处理第一个带VIP的包
  27. function deal_with_packet_1(data, st, ed)
  28.         dbg("deal with packet 1")
  29.        
  30.         --首个字节为包总长度
  31.         local total_len = string.byte(data, 1)
  32.         local packet_len = total_len + 2
  33.         --总长度差额
  34.         local total_len_diff = 0;
  35.        
  36.         --新旧IP字符串长度
  37.         local old_ip_len = ed - st + 1
  38.         local new_ip_len = string.len(rs.ip)
  39.         local len_diff = 0
  40.        
  41.         dbg("total_len: "..total_len)
  42.         dbg("new ip len: "..new_ip_len..", old_ip_len: "..old_ip_len)
  43.        
  44.         len_diff = new_ip_len - old_ip_len
  45.         total_len_diff = len_diff

  46.         --若差额是奇数,考虑补位和总长度
  47.         if total_len_diff % 2 ~= 0
  48.         then
  49.                 --若最后一位是0
  50.                 if string.byte(data, packet_len) == 0
  51.                 then
  52.                         dbg("last byte == 0")
  53.                         --长度-1,去掉最后的0
  54.                         total_len_diff = total_len_diff - 1
  55.                         TCP.replace(packet_len, packet_len + 1, "")
  56.                        
  57.                 --若最后一位非0
  58.                 else
  59.                         dbg("last byte != 0")
  60.                         --长度+1,同时需要补位
  61.                         total_len_diff = total_len_diff + 1
  62.                         TCP.append(0)
  63.                 end
  64.         end
  65.        
  66.         dbg("len_dif: "..len_diff..", data[5]: "..string.byte(data, 5)..", data[st - 2]: "..string.byte(data, st - 2))
  67.         dbg("total_len_diff: "..total_len_diff)
  68.        
  69.         --替换为调度的服务器的IP
  70.         TCP.replace(st, ed + 1, rs.ip)
  71.        
  72.         --替换data[5]和data[st - 2]位置的长度
  73.         TCP.replace(5, 6, string.char(string.byte(data, 5) + len_diff))
  74.         TCP.replace(st - 2, st - 1, string.char(string.byte(data, st - 2) + len_diff))
  75.        
  76.         --修改包总长度
  77.         TCP.replace(1, 2, string.char(total_len + total_len_diff))
  78.        
  79.         dbg("deal with packet 1 finish")
  80. end

  81. --处理第二个带VIP的包
  82. function deal_with_packet_2(data, st, ed)
  83.         dbg("deal with packet 2")
  84.        
  85.         --首个字节为包总长度
  86.         local total_len = string.byte(data, 1)
  87.         --总长度差额
  88.         local total_len_diff = 0;
  89.        
  90.         --新旧IP字符串长度
  91.         local old_ip_len = ed - st + 1
  92.         local new_ip_len = string.len(rs.ip)
  93.         local len_diff = 0
  94.                
  95.         dbg("total_len: "..total_len)
  96.         dbg("new ip len: "..new_ip_len..", old_ip_len: "..old_ip_len)

  97.         len_diff = new_ip_len - old_ip_len
  98.         total_len_diff = len_diff       
  99.        
  100.         dbg("len_dif: "..len_diff..", data[5]: "..string.byte(data, 5))
  101.         dbg("total_len_diff: "..total_len_diff)
  102.        
  103.         --替换为调度的服务器的IP
  104.         TCP.replace(st, ed + 1, rs.ip)
  105.        
  106.         --替换data[5]位置的长度
  107.         TCP.replace(5, 6, string.char(string.byte(data, 5) + len_diff))
  108.        
  109.         --修改包总长度
  110.         TCP.replace(1, 2, string.char(total_len + total_len_diff))
  111.        
  112.         dbg("deal with packet 2 finish")
  113. end

  114. event CLIENT_DATA
  115. {
  116.     dbg("CLIENT_DATA")
  117.        
  118.         local data = TCP.payload()
  119.        
  120.         if not data
  121.         then
  122.                 return 0
  123.         end
  124.        
  125.         local st, ed = 0, 0
  126.        
  127.         local vip = TCP.localaddr()
  128.        
  129.         dbg("vip: "..vip)
  130.        
  131.         --查找VIP
  132.         st, ed = string.find(data, vip, ed + 1)
  133.        
  134.         if not st
  135.         then
  136.                 dbg("can't find vip "..vip)
  137.                
  138.                 TCP.release()
  139.                 TCP.collect()
  140.                
  141.                 return 0
  142.         end
  143.        
  144.         if packet == 1
  145.         then
  146.                 deal_with_packet_1(data, st, ed)
  147.                 --后面继续收集数据
  148.                 TCP.collect()
  149.         elseif packet == 2
  150.         then
  151.                 deal_with_packet_2(data, st, ed)
  152.                 --后面的包不再处理
  153.         else
  154.                 dbg("ERROR: stop!")
  155.         end
  156.        
  157.         dbg("finish, packet "..packet)
  158.        
  159.         packet = packet + 1
  160.        
  161.         TCP.release()
  162. }
复制代码

打赏鼓励作者,期待更多好文!

打赏
暂无人打赏

粉色的小猪在天上飞 发表于 2017-3-30 11:52
  
这个可以有
哥丶珍藏版 发表于 2017-3-30 22:09
  
了解下
新手195199 发表于 2017-3-31 15:18
  
没看到代码呢。。。
发表新帖
热门标签
全部标签>
西北区每日一问
安全效果
高手请过招
【 社区to talk】
每日一问
产品连连看
干货满满
标准化排查
新版本体验
社区新周刊
GIF动图学习
纪元平台
自助服务平台操作指引
技术咨询
解决方案
社区帮助指南
秒懂零信任
每周精选
功能体验
技术盲盒
信服课堂视频
畅聊IT
答题自测
专家问答
技术笔记
技术圆桌
在线直播
MVP
网络基础知识
安装部署配置
升级
安全攻防
上网策略
测试报告
日志审计
问题分析处理
流量管理
每日一记
运维工具
云计算知识
用户认证
原创分享
sangfor周刊
VPN 对接
项目案例
SANGFOR资讯
专家分享
技术顾问
信服故事
SDP百科
功能咨询
终端接入
授权
设备维护
资源访问
地址转换
虚拟机
存储
迁移
加速技术
排障笔记本
产品预警公告
玩转零信任
信服圈儿
S豆商城资讯
技术争霸赛
「智能机器人」
追光者计划
深信服技术支持平台
答题榜单公布
2023技术争霸赛专题
通用技术
卧龙计划
华北区拉练
天逸直播
以战代练
技术晨报
山东区技术晨报
文档捉虫活动
齐鲁TV
华北区交付直播
2024年技术争霸赛
北京区每日一练
场景专题
故障笔记
排障那些事
升级&主动服务
高频问题集锦
POC测试案例
全能先锋系列
云化安全能力

本版达人

新手61940...

本周建议达人

zhao_HN

本周分享达人

ZSFKF

本周提问达人