文档章节

Python -- socket 实现服务器之间的通信

o
 osc_a7a1prn6
发布于 07/04 07:27
字数 806
阅读 20
收藏 0

行业解决方案、产品招募中!想赚钱就来传!>>>

  现在需要做一个分布式课程设计(简单小游戏),三个人小组合作完成。

  我需要设计一个登录注册服务器,接收来自网关服务器(消息中间件)的用户登录注册消息请求,然后生成访问数据库服务器的消息,发送给数据库服务器,接收并处理其返回信息,发送登录注册结果给网关服务器。(很简单的功能)

  我的想法是:登录注册服务器主线程一直运行,监控是否有来自网关服务器的连接请求。每当接收到一次连接请求时,开辟一个新的子线程,处理来自网关服务器的消息请求,并生成访问数据库的请求消息,发送给数据库服务器,随即接收返回的数据库操作信息,子线程处理后发送登录注册结果给网关服务器。

  编程语言:Python 

  网络通信方式:tcp(具体使用socket)

  数据交换格式:json

  流程图:

  代码如下:

 1 Server.py
 2 
 3 # -*- coding: UTF-8 -*-
 4 import socket
 5 import datetime
 6 import time
 7 import json
 8 
 9 class Server(object):
10     """Server Side"""
11     
12     def __init__(self):
13         self.host = '219.224.167.162'
14         self.port = 6999
15         Arr=(self.host,self.port)
16         self.s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
17         self.s.bind(Arr)
18         self.s.listen(5) #操作系统可以挂起的最大连接数量
19         
20     def ReceiveMSG(self, threadname, sk_conn):
21         try:
22             msg_conn = sk_conn.recv(1024).decode()
23             data_conn= json.loads(msg_conn)
24             print(data_conn)
25             #访问数据库服务器
26             sk_db = socket.socket()        # 创建 socket 对象
27             host = '219.224.167.250'    # 获取数据库服务器主机名
28             port = 9999                 # 设置端口号
29             sk_db.connect((host, port))
30             #分析客户端 登录or注册
31             if data_conn[0]['OP']=='login':
32                 print('  -【登录】:',data_conn)
33                 data=[{'OP':'login','username':'%s'%(data_conn[0]['username'])}]
34                 msg=json.dumps(data)
35                 sk_db.send(msg.encode())
36                 print('  -数据库服务器返回:')
37                 while True:
38                     msg=sk_db.recv(1024).decode()
39                     print('    ',msg)
40                     if msg=='Close!':
41                         sk_db.close()
42                         break
43                     if msg=='Welcome!':
44                         continue
45                     else:
46                         data=json.loads(msg)
47                         sk_db.send(b'exit')
48                         if data[0]['password']=='None':
49                             data=[{'code':1,'info':'Failed for error username!'}]
50                         elif data[0]['password']!=data_conn[0]['password']:
51                             data=[{'code':2,'info':'Failed for error password!'}]
52                         else:
53                             data=[{'code':3,'info':'success!'}]
54                  
55                 ##返回信息到客户端
56                 #data=[{'code':3,'info':'success!'}]#
57                 msg=json.dumps(data)
58                 print('    返回客户端信息: ',msg)
59                 sk_conn.send(msg.encode())
60                 sk_conn.close()
61             else:
62                 print('  -【注册】:',data_conn)
63                 data=data_conn
64                 msg=json.dumps(data)
65                 sk_db.send(msg.encode())
66                 print('  -数据库服务器返回:')
67                 while True:
68                     msg=sk_db.recv(1024).decode()
69                     print('    ',msg)
70                     if msg=='Close!':
71                         sk_db.close()
72                         break
73                     if msg=='Welcome!':
74                         continue
75                     else:
76                         data=json.loads(msg)
77                         sk_db.send(b'exit')
78                         if data[0]['msg']=='success':
79                             data=[{'code':4,'info':'success'}]
80                         else:
81                             data=[{'code':5,'info':'fail'}]
82                 #data=[{'code':4,'info':'success'}]#
83                 #返回信息到客户端
84                 msg=json.dumps(data)
85                 print('    返回客户端信息: ',msg)
86                 sk_conn.send(msg.encode())
87                 sk_conn.close()
88         except BaseException:
89              print('An unknow error occurred.')
90             
91     def __delattr__(self):
92         self.sock.close()
93         self.s.close()

 

 1 LoginRegisterServer.py
 2 主线程
 3 
 4 # -*- coding: UTF-8 -*-
 5 import _thread
 6 import time
 7 import json
 8 from Server import Server
 9 from Client import Client
10 
11 print('服务器已启动,开始提供 【登录 注册】 服务...\n')
12 server=Server()
13 
14 while True:
15     sk_conn,addr = server.s.accept()
16     print('\n请求链接用户信息:', addr)
17     
18     try:
19         _thread.start_new_thread( server.ReceiveMSG, ("Thread: deal with request.", sk_conn) )
20     except:
21         print("Error: unable to start thread")

 

o
粉丝 0
博文 69
码字总数 0
作品 0
私信 提问
加载中
请先登录后再评论。
用vertx实现高吞吐量的站点计数器

工具:vertx,redis,mongodb,log4j 源代码地址:https://github.com/jianglibo/visitrank 先看架构图: 如果你不熟悉vertx,请先google一下。我这里将vertx当作一个容器,上面所有的圆圈要...

jianglibo
2014/04/03
4.1K
3
SQLServer实现split分割字符串到列

网上已有人实现sqlserver的split函数可将字符串分割成行,但是我们习惯了split返回数组或者列表,因此这里对其做一些改动,最终实现也许不尽如意,但是也能解决一些问题。 先贴上某大牛写的s...

cwalet
2014/05/21
9.6K
0
树莓派(Raspberry Pi):完美的家用服务器

自从树莓派发布后,所有在互联网上的网站为此激动人心的设备提供了很多有趣和具有挑战性的使用方法。虽然这些想法都很棒,但树莓派( RPi )最明显却又是最不吸引人的用处是:创建你的完美家用...

异次元
2013/11/09
6.6K
8
漏洞检测工具--Peach Fuzzer

Peach是一种用Python编写的 Fuzzer。这种工具有助于发现并公开许多漏洞,并认为是黑客和安全团体中最流行的工具之一。为了利用Peach框架,必须创建Phthon脚本,脚本 中包含了在服务器上执行的...

匿名
2013/02/06
8.8K
1
Javascript图元绘制库--ternlight

基于HTML CANVAS API的Javascript库,提供在HTML页面上绘制图元——如流程图的能力。 目前已支持简单的矩形图元和图元间的连线(直线、直角连线两种),拖拽图元等能力。 该javascript librar...

fancimage1
2013/02/07
6.3K
1

没有更多内容

加载失败,请刷新页面

加载更多

PHP中的startsWith()和endsWith()函数 - startsWith() and endsWith() functions in PHP

问题: How can I write two functions that would take a string and return if it starts with the specified character/string or ends with it? 我如何编写两个带字符串的函数,如果它以......

技术盛宴
7分钟前
0
0
OSChina 周一乱弹 —— 你想用屁治疗一下谁

Osc乱弹歌单(2020)请戳(这里) 【今日歌曲】 @薛定谔的兄弟 :分享洛神有语创建的歌单「我喜欢的音乐」: 《Rain in the Park》- Marika Takeuchi 手机党少年们想听歌,请使劲儿戳(这里)...

小小编辑
11分钟前
14
0
在C#中调用基本构造函数 - Calling the base constructor in C#

问题: If I inherit from a base class and want to pass something from the constructor of the inherited class to the constructor of the base class, how do I do that? 如果我从基类......

富含淀粉
37分钟前
7
0
用Python构建个性化智能闹钟

作者|Kumar Shubham 编译|VK 来源|Towards Data Science 你可能之前有见过有人使用Python语言构建闹钟,帮助他唤醒或提醒他一个重要的会议。 这些都是很简单,没有任何智能,他们所做的只是播...

人工智能遇见磐创
46分钟前
18
0
前端学数据结构与算法(二):数组与栈

前言 数据结构与算法有相互依存的关系,如果将这个两个又进行划分,无疑数据结构又是这座大厦的基础。首先从线性数据结构开始,介绍大家耳熟能详的数据结构-数组。因为JavaScript已经为数组封...

飞跃疯人院
55分钟前
7
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部