项目介绍

本次作业是为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配置代理，现在算是知道了。

第三次作业：后台的实现