项目介绍
本次作业是为app程序编写后端，能够在http请求以后返回app需要的JSON文件，并能够通过服务器向数据库插入数据
题目分析：
app有两种主要页面：
第一种页面需要得到的就是聊天室的JSON，第二种页面需要得到的是聊天信息的JSON。（http的get请求）
第二种页面还需要实现发送信息，把信息存入数据库。（http的post请求）
所以后台大概怒就做这三件事
如何开发后台
开发工具：sublime text
开发环境：ubuntu
开发语言：python，SQL 框架：flask
Step1：搭建数据库
这部分就简单介绍好了
数据库建两个，一个放聊天室，一个放聊天信息。
大概就这么建：
USE iems5722;
CREATE TABLE `chatrooms` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(100) NOT NULL,
PRIMARY KEY (`id`)
) DEFAULT CHARSET=utf8;
CREATE TABLE IF NOT EXISTS `messages` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`chatroom_id` varchar(11) NOT NULL,
`user_id` varchar(11) NOT NULL,
`name` varchar(100) NOT NULL,
`message` varchar(300) NOT NULL,
`timestamp` datetime NOT NULL,
PRIMARY KEY (`id`)
) DEFAULT CHARSET=utf8;
Step2：编写py文件,根据http请求处理数据库
首先应该编写一个Mydatabase.py的文件，让我们能够处理数据库的文件（连接数据库）。
import MySQLdb
class MyDatabase:
db = None
def __init__(self):
self.connect()
return
def connect(self):
self.db = MySQLdb.connect(
host = "localhost",
port = 3306,
user = "root",
passwd = "******",
db = "iems5722",
use_unicode = True,
charset = "utf8",
)
self.cursor = self.db.cursor(MySQLdb.cursors.DictCursor)
return
然后呢，再主要的py文件里，导入上面这个包开始做嘢，
import MyDatabase as md
做三件微小的工作：
1.得到聊天室JSON
这部分比较简单，直接贴代码如下
@app.route('/api/assgn3/get_chatrooms',methods=['GET'])
def get_chatrooms():
db = md.MyDatabase()
query = "SELECT id,name FROM CHATROOMS ORDER BY id ASC"
#excute the query
db.cursor.execute(query)
#get the result(rows)
rows = db.cursor.fetchall()
data = []
data = rows
return jsonify(status = "OK",data=data)
@app.route('/api/assgn3/get_messages',methods=['GET'])
2.得到聊天室的聊天记录
这部分稍微复杂，我们大家知道聊天室都是有分页的，当前页和总的页数一定要得到，app才能处理
@app.route('/api/assgn3/get_messages',methods=['GET'])
def get_messages():
data =[]
cur_page = request.args.get("page",)
chatroom_id = request.args.get("chatroom_id")
db = md.MyDatabase()
chatroom_id = str(chatroom_id)
query = "SELECT * FROM messages Where chatroom_id =" + chatroom_id + " ORDER BY id DESC"
db.cursor.execute(query)
data = db.cursor.fetchall()
'''
The part below is to generate cur_page and total page
'''
total = len(data)/20 + 1
cur_page = int(cur_page)
start = (cur_page-1)*20
end = start +20
if end > len(data):
end = len(data)-1
data_need = data[start:end]
print len(data_need)
return jsonify(status = "OK",page = cur_page,total_pages = total,data =data_need)
3.在聊天室发送信息
get是select可想而知post就是insert了，废话不多说直接上代码了。
def send_message():
my_db = md.MyDatabase()
msg = request.form.get("message")
name = request.form.get("name")
chatroom_id = request.form.get("chatroom_id")
user_id = request.form.get("user_id")
# Get chatroom name
select_chatroomname_query = "SELECT name from CHATROOMS where id = %s" % chatroom_id
my_db.cursor.execute(select_chatroomname_query)
chatroom_name_json = my_db.cursor.fetchone()
chatroom_name = chatroom_name_json['name']
if msg == None or chatroom_id == None or name == None or user_id == None :
return jsonify(status="ERROR", message="missing parameters")
query = "INSERT INTO messages (chatroom_id,user_id,name,timestamp,message) values(%s,%s,%s,%s,%s)"
parameters = (chatroom_id,user_id,name,time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time()+8*3600)),msg)
my_db.cursor.execute(query,parameters)
my_db.db.commit()
return jsonify(status="OK")
注意考虑一些参数为空的情况
以上的代码都是怎么调试的呢？
三步：
1.把代码放到服务器
2.运行该段代码
$ python app.py
3.用postman测试 http://xxx.xxx.xxx.xxx:5000/api/assgn3/...
调试好了，一切正常以后做下一步：
Step3：配置服务器
简单来说是用Gunicorn+Supervisor+Nginx实现的，本文就不再赘述了，参考
<a href="https://github.com/leoymr/Android-self-learning/blob/master/android-server%E9%85%8D%E7%BD%AE.md">Gunicorn+Supervisor+Nginx配置</a>
这里仅给出两个配置文件的内容：
1. supervisord.conf
[program:iems5722]
command = gunicorn getAPI:app -b 0.0.0.0:8000
directory = /home/ubuntu/app
user = ubuntu
autostart = true
autorestart = true
stdout_logfile = /home/ubuntu/appFlask/app.log
redirect_stderr = true
2.iems5722.conf
server {
listen 80;
listen [::]:80;
root /home/ubuntu/app;
index index.php index.html index.htm;
server_name 0.0.0.0;
location /api/asgn3/ {
proxy_pass http://0.0.0.0:8000;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header Host $http_host;
proxy_http_version 1.1;
proxy_redirect off;
proxy_buffering off;
}
}
总结
这次作业让我熟悉了python flask和nginx的配置，后来还利用所学给<a href="http://www.kevinhuang.top">自己的主页</a>配置了nginx,也算受益匪浅了，去年给创业公司建站的时候就一直琢磨怎么用nginx配置代理，现在算是知道了。
