This package has been deprecated

Author message:

Package no longer supported. Contact Support at https://www.npmjs.com/support for more info.

etm

ETM NodeJs 服务器框架

ETM使用的是typescript和express的组合， 同时封装了MySQL，已方便直接使用， 只需要进行简单的配置即可创建好一个nodejs web服务器。

如何安装？

npm install ets --save

ETM提供了哪些模块？

• ETM （服务器主要模块）

• Config （服务器配置）

• Route （路由）

• HttpsCert （https协议证书类）

• Protocol （网络协议）

• ViewEngine （视图引擎）

• StyleSheet （样式表）

• MySQL （MySQL数据库操作）

• MySQLConfig （MySQL数据库配置）

• WebSocketHandler (Websocket消息处理)

如何创建一个服务器？

创建服务器需要以下三部

• new一个ETM对象，传入服务器选项
• 调用addRoute方法添加路由
• 调用createServer方法创建服务器

示例如下

//初始化服务器
let server = new ETM(config);
//添加路由
server.addRoute('', Index);
//创建服务器
server.createServer();

服务器选项有哪些？

• 端口号（默认是3000，使用setPort方法更改端口号）
• 服务器协议（默认是Protocol.HTTP，使用setProtocol方法更改协议类型，如果是https则必须传证书参数）
• https证书（如果服务器协议为Protocol.HTTPS，则必须传入证书）
• 跨域访问（默认是false，使用crossDomain方法可以设置是否跨域）
• 文件上传缓存目录（默认/tmp/ets，使用setCachePath方法设置）
• 网页静态资源目录（必须设置，使用setStaticPath方法设置）
• 视图目录（必须设置，使用setView方法设置）
• 视图引擎（默认是ViewEngine.hbs，使用setView方法可以更改）
• 样式表（默认是StyleSheet.less，使用setView方法可以更改）

如何创建https服务器？

创建https服务器需要提供证书。

将证书放到任意目录（一般在项目中新建一个cert目录放置https证书）。

使用new HttpsCert(.key文件的绝对路径，.pem文件的绝对路径) 创建一个证书对象。

new Config()之后调用setProtocol方法设置服务器为https服务器，同时设置证书配置。

其他的完全和http一样

如何使用MySQL？

MySQL的使用非常简单，最简单的方法如下：

• 在入口文件处创建一个常用mysql对象: let mysqlConf = MySQLConfig.common(host, user, password, database);
• MySQL.makeConfig(mysqlConf)
• 如果要自定义配置则需要先new MySQLConfig()，然后调用相应的方法进行设置。

如何执行sql语句

使用MySQL.getMySQL()方法可以获取MySQL连接， 获取到连接地址之后就可以调用query方法执行sql语句了。 所有操作完成后需要调用release方法进行释放。

注意：新版本加入了quickQuery这样一个静态方法可以方便地执行sql语句

下面的示例中以一个简单的路由进行演示：

//导入相关库
import {Route, MySQL} from './../../index';
 
//创建一个路由
class IndexRoute extends Route {
 
    //获取指定年龄的用户并进行分页
    public async getUsers({age, page, every}:any) {
        age = parseInt(age);
        page = parseInt(page);
        every = parseInt(every);
        let mysql = await MySQL.getMySQL();
        console.log(mysql);
        let users = await mysql.query('select * from ?? where ? limit ?, ?', 'user', {age}, page * every, every);
        this.json(users);
        mysql.release();
    }
 
    //添加一个用户
    public async addUser({name, age}:any) {
        let mysql = await MySQL.getMySQL();
        let result = await mysql.query('insert into ?? (??, ??) values (?,?)', 'user', 'name', 'age', name, age);
        let id = result.insertId;
        this.json(id);
        //或者
        let {insertId} = await mysql.query('insert into ?? (??, ??) values (?,?)', 'user', 'name', 'age', name, age);
        this.json(insertId);
        mysql.release();
    }
 
    //测试错误捕获
    public async errorTest() {
        let mysql = MySQL.getMySQL();
        try {
            let users = await mysql.query('select * from usre ');		//故意写错user为usre
            this.json(users);
        } catch (e) {
            //打印错误
            console.log(e);
            this.json('获取用户失败');
        }
        mysql.release();
    }
 
    //测试事务处理
    public async testTrans() {
        let uid = 10;
        let mysql = MySQL.getMySQL();
        try {
            mysql.startTrans();
            let {insertId:head} = mysql.query('insert into ?? (??) values (?)', 'head', 'url', '/public/head/use_1.png');
            mysql.query('update ?? set ? where ?', 'user', {head}, {id: uid});
            mysql.commit();
            this.json('ok');
        } catch (e) {
            console.log(e);
            mysql.rollback();
            this.json('error');
        }
        mysql.release();
    }
}
 
//导出路由，以在项目入口文件中往服务器中添加该路由
export default IndexRoute;

如何使用WebSocket

服务器已集成了websocket， 通过简单的配置即可快速使用。

• 如果服务器是http服务器，则websocket为ws://
• 如果服务器是https服务器，则websocket为：wss://

要使用websocket很简单，只需要如下几步。

1、配置服务器

config.setUseWebSocket(true);

2、在服务器创建完成之后配置websocket消息处理类

server.getWebSocket().setHandler(WSHandler);

关于Websocket中消息处理类的写法

• 需要继承自WebSocketHandler类
• 实现onMessage方法

下面是一个例子

import {WebSocketHandler} from './../../index';
 
interface SocketParam {
    name: string,
    age: number
}
 
class WSHandler extends WebSocketHandler<SocketParam> {
    onMessage(data: any) {
        switch (data.type) {
            case 'hello':
                this.send("hello world");
                break;
            case "info":
                this.send({
                    name: 'Jane',
                    age: 20
                });
                break;
            default:
                this.send({
                    error: 'other messages'
                });
        }
    }
}
 
export default WSHandler;