基于Python和Java实现的业务数据分析处理传输系统

红太狼 2024-03-26 12:29 49阅读 0赞

目录  
《软件体系结构与设计》实习报告 1  
一、实验概况 2  
二、实验设计(给出你的实习内容的设计方案，可根据实际情况调整条目) 1  
2.1 系统需求 1  
2.2 架构设计 1  
客户端： 2  
数据处理： 2  
链接 Java 2  
Java 访问 DB： 2  
2.3 接口设计 2  
三、实验过程 3.1 软件实现 3  
3.2 实验环境 3  
图 3 链接 SQS 和链接数据库接口功能的验证 3  
图 4 服务层消息发送和逻辑层消息接收 4  
图 5 数据库查询完成 4  
图 6 本地部署三层架构完成 4  
四、实验评价 4.1 实验结果 5  
4.2 结果分析 5  
五、总结 6  
1.结合以下示例数据库或自选其他相当规模数据集，使用 Java 设计实现一个三层架构的业务数据分析系统。各逻辑层的功能如下：  
表现层：包含输入、查询相关的控件以及数据图表的展示（如百分图，折线图）； 业务逻辑层：数据处理、数据分析（不少于三项统计分析功能）、数据查询；  
数据访问层：负责数据库的访问，主要职责为打开、关闭数据库、构建 SQL 查询、返回查询结果。  
附：SqlServer 示例数据库 Northwind  
https://www.cnblogs.com/mahongbiao/p/3764782.html  
附：上证 1999-2016 的某公司股票走势数据，构建其业务数据分析系统。  
2.修改程序以适应三个逻辑层的分布式部署，要求三个逻辑分层分别部署于客户机（本机或手机）、AWS EC2 应用服务器和 AWC RDS 数据库服务器上（即多层 C/S 架构），部署完成后能通过公网 IP 访问该系统。  
3.使用 RSA 或 Visio 等建模工具构建软件架构模型（UML 图），要求：

（1）画出逻辑分层结构图；

（2）画出每个逻辑层中所包含的核心构件（此处为类）；

（3）画出每个逻辑层中构件（类）之间的关系，且要细化到聚合(Aggregation)、组成（Composition）关系并给出重数（如 1:1,1:\*）；  
（4）画出系统部署结构图。

二、实验设计(给出你的实习内容的设计方案，可根据实际情况调整条目)  
2.1系统需求

环境需求：  
① 用户需要在 C:\\Users\\用户名.aws 目录下设置 credentials 和 config 文件，用以保存自己的 AWS 账号信息。  
② 用户只需要在一个终端进行操作，不需要管剩下几层是怎么运作的。功能需求：  
系统需要分为三层，每一层的进程分别在不同的主机上运行，因此需要完成：  
① 客户端明确的操作界面  
② 业务逻辑层完成数据处理  
③ 数据访问层完成数据库的访问  
④ 完成三层之间的通信过程  
⑤ 各个程序需要部署在不同的主机质量需求：  
在遇到错误指令或者系统内部发生错误后可以显示出来，不会因此导致程序崩溃。

from tkinter import *
    from AWS.SQSVister import *
    from AWS.JavaSQLVister import *
    import _thread
    import time
    import jpype
    import os
    
    
    class Work:
          sql = JavaSQLVisiter()
          def __init__(self):
                print('业务逻辑启动')
    
          #处理值
          def ReturnValue(self,res,str_output):
                str_output = str_output+' '
                for i in range(len(res)):
                      charu = ''.join(str(res[i]))
                      if 'N/A' in charu:
                            charu = '0'
                      str_output = str_output + charu + ' '
                return str_output
    
                
          #发送值
          def Send(self,my_list,which):
                print('发送到'+which)
                if which == 'J':
                      SQS = SQSVisiter('JJ')    
                elif which == 'S':
                      SQS = SQSVisiter('SZZS')
                elif which == 'C':
                      SQS = SQSVisiter('CJL')
                      
                for each in my_list:
                      SQS.SendMessage(each)
          
          #访问数据库
          def VisSQL(self,which):
                print(which)
                if which == 'J':
                      res1 = self.sql.Search('日期')
                      res2 = self.sql.Search('均价')
    
                      x = self.ReturnValue(res1,'x')
                      y = self.ReturnValue(res2,'y')
    
                      self.Send([x,y],which)
                      
                
                elif which == 'S':
                      res1 = self.sql.Search('日期')
                      res2 = self.sql.Search('总市值')
                      
                      another_y = []
                      ans = 100
                      front = (float)(res2[0])
                      for each in res2:
                            each = (float)(each)
                            another_y.append(ans*(1.0+(each-front)/(front*1.0)))
                            ans = another_y[len(another_y)-1]
                            front = each
                      x = self.ReturnValue(res1,'x')
                      y = self.ReturnValue(another_y,'y')
    
                      self.Send([x,y],which)
    
                      
                
                elif which == 'C':
                      
                      res0 = self.sql.Search('日期')
                      res1 = self.sql.Search('开盘价')
                      res2 = self.sql.Search('最高价')
                      res3 = self.sql.Search('最低价')
                      res4 = self.sql.Search('收盘价')
    
                      res0 = self.ReturnValue(res0,'x')
                      res1 = self.ReturnValue(res1,'y1')
                      res2 = self.ReturnValue(res2,'y2')
                      res3 = self.ReturnValue(res3,'y3')
                      res4 = self.ReturnValue(res4,'y4')
    
                      self.Send([res0,res1,res2,res3,res4],which)
                      
    
    
          
                   
          #一直接收消息
          def ReciveMessage(self):
                while True:
                     SQSLayer = SQSVisiter('ThreeLayer')
                     print('开始接收消息')
                     rt = SQSLayer.GetMessage()
                     if rt != []:
                           for each in rt:
                                 print(each)
                                 self.VisSQL(each[0])
                                 
                           SQSLayer.DelMessage()
                     time.sleep(5)
                
    
    if __name__ == '__main__':
          work = Work()
          #work.VisSQL('C')
          work.ReciveMessage()

![在这里插入图片描述][1b85e11ef2784adabd392abb43c0722b.png_pic_center]  
![在这里插入图片描述][8b89b1a35b0b48b9ba1cd2ff55f6d375.png_pic_center]  
![在这里插入图片描述][a7f7eb4f7ea7477587be63cabb880b8b.png_pic_center]  
![在这里插入图片描述][264360988f1b4003bb508c20b600de84.png_pic_center]  
![在这里插入图片描述][2f68e2f3cb7f4113af5655408350e46d.png_pic_center]  
![在这里插入图片描述][c964d745ca2a46f8bb4d2a21a5d50011.png_pic_center]  
![在这里插入图片描述][a1692c007c53417b81db84ec7a801c66.png_pic_center]  
![在这里插入图片描述][194ee4679b874c6bb2fc4b5de7887736.png_pic_center]  
![在这里插入图片描述][39848f51e183473a8f483362d051682f.png_pic_center]  
![在这里插入图片描述][70bf3e2331b84072a5228a8e2d107cc2.png_pic_center]  
![在这里插入图片描述][93c46a00bf074691823b28f247fd9911.png_pic_center]  
![在这里插入图片描述][90148bd86d1d40a5a7970d6ed2dc75b1.png_pic_center]

[1b85e11ef2784adabd392abb43c0722b.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/06ef752d304a40f8b800f06ffd92632f.png
[8b89b1a35b0b48b9ba1cd2ff55f6d375.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/066f7810b70d472b9105b6f76fb9c16f.png
[a7f7eb4f7ea7477587be63cabb880b8b.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/8821eedd8236466cbc5266677d2b5131.png
[264360988f1b4003bb508c20b600de84.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/201c4670430c4d768fbf3beee9f0df90.png
[2f68e2f3cb7f4113af5655408350e46d.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/7d6343e598d34648bbbe93ab4a6241e0.png
[c964d745ca2a46f8bb4d2a21a5d50011.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/2a4c4b5e36a14358adfce6b40e648821.png
[a1692c007c53417b81db84ec7a801c66.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/ffbb2bdf0729484e9f9ecca6948543e9.png
[194ee4679b874c6bb2fc4b5de7887736.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/c323f083b1174467abad96ebd754c79b.png
[39848f51e183473a8f483362d051682f.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/c171cf27f59e43ce9b1e94757108196c.png
[70bf3e2331b84072a5228a8e2d107cc2.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/b069d9372bd942a7af161097e203a650.png
[93c46a00bf074691823b28f247fd9911.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/81e7ea3c317848c1b69400bfd678f658.png
[90148bd86d1d40a5a7970d6ed2dc75b1.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/8fe1eadb86c24e498ece53de7952dece.png