Yêu cầu
- Biết chút ít về JSP/Servlet và mô hình MVC, bạn có thể đọc bài viết của mình tại đây
- Lập trình socket với java, đọc tại đây
- Ngôn ngữ truy vấn SQL(biết 1 chắc biết cái này)
Tạo và cấu hình các projects
Chúng ta sẽ xây dựng 3 chức năng chính cho web service là:- Lưu trữ dữ liệu vào database.
- Xử lý yêu cầu và gửi phản hồi cho app.
- Giao tiếp với các thiết bị.
Đầu tiên mở eclipse lên và tạo 1 dynamic project tên là MyWS(my web service), ở đây mình dùng tomcat8.
Tiếp theo ta cấu hình java build path của MyWS như sau: vào tab projects và chọn add.. sau đó tick vào shared project rồi chọn OK.
Sau bước này thì MyWS sẽ tự động link đến shared project.Vào Web Deployment Assembly rồi chọn Add… –> Project –> Shared sau đó Finish. Làm bước này để khi deploy MyWS sẽ tự động tạo ra thư viện shared.jar và add vào folder chứa thư viện của MyWS, như thế sẽ tránh được lỗi không tìm thấy class lúc runtime(mặt dù lúc biên dịch hoặc export ra war file vẩn ko báo lỗi).
| Tên file | Hệ điều hành |
|---|---|
| libsqlite4java-linux-amd64.so | Linux 64bit |
| libsqlite4java-linux-i386.so | Linux 32bit |
| sqlite4java-win32-x64.dll | Windows 64bit |
| sqlite4java-win32-x86.dll | Windows 32bit |
| libsqlite4java-linux-arm.so | Linux ARM(PI2) |
Thực ra sqlite4java.jar chỉ là 1 wrap library để dể dàng giao làm việc với SQLite database, nó sẽ gọi các hàm chính trong native library.
Xây dựng csdl
Tiếp theo ta định nghĩa các bảng dữ liệu của web service:tb_energy: ta dùng bảng này để lưu lịch sử điện năng tiêu thụ của các thiết bị, thực ra chúng ta có thể tạo cho mỗi thiết bị 1 bảng energy riêng để việc truy vấn nhanh hơn(vì chủ yếu truy vấn theo từng thiết bị).
| device_id | energy | utc |
|---|---|---|
| INT4 | INT4 | INT4 |
| device_id | name |
|---|---|
| INT4 | nvarchar(50) |
| id | username | password_hash |
|---|---|---|
| INTEGER | nvarchar(25) | nvarchar(1000) |
Xây dựng Model java bean
Trong Shared project ta tạo các java bean như sau:Energy class lưu trữ thông tin điện năng tiêu thụ của thiết bị bao gồm id, gía trị điện năng và thời gian ghi nhận:
public class Energy implements Serializable {
private static final long serialVersionUID = 1L;
private int deviceId;// device id
private int energy;// energy value
private int utc;// time :|
....
}public class Account implements Serializable {
private static final long serialVersionUID = 1L;
private int id;
private String userName;
private String passwordHash;
....
}public class Device implements Serializable {
private static final long serialVersionUID = 1L;
private int id;
private String name;
....
}public class RealTime implements Serializable {
private static final long serialVersionUID = 1L;
private int power;
private short voltage;
private int amperage;
private byte state;
....
}Các bạn chú ý là mỗi class java bean trên đều thực thi từ giao diện Serializable, mục đích là cho phép java convert thực thể của java bean này thành mảng byte để có thể truyền đi qua mạng :|
Cái trường serialVersionUID thực ra không cần cũng được cơ mà xóa thì nó warning nhìn nhứt mắt lắm :|. Mục đích của trường này là để xác định phiên bản của class java bean này mỗi lần nó serial hoặc deserial…Ví dụ thế này nhé: class RealTime hiện tại có 4 trường lần lượt như trên, ta mã hóa thành mảng byte rồi lưu đâu đó, tiếp theo ta thêm 1 trường xyz nào đó vào class RealTime này rồi convert dữ liệu đã lưu lại thành thực thể của class RealTime(hiện tại có tới 5 trường thay vì 4 như lúc nảy) thì chuyện gì sẽ xảy ra với trường thứ 5 là xyz :| nó sẽ có gía trị bao nhiêu?
Xây dựng Model DAO
Ta định nghĩa giao diện giao tiếp csdl ISQLDb cho DAO như sau:// open database
void open();
// close database
void close();
// add an energy to database
void addEnergy(Energy energy);
// get energies of a device
List<Energy> getEnergies(int deviceId);
// get energies of a device in period
List<Energy> getEnergies(int deviceId, int beginUTC, int endUTC);
// add new device to database
void addDevice(Device newDevice);
// get device info by id
Device getDevice(int deviceId);
// get all devices in database
List<Device> getAllDevices();
// update device info
void updateDevice(Device device);
// add new account to database
void addAccount(Account account);
// remove an exist account by id
void removeAccount(int id);
// get an exist account by user name
Account getAccount(String username);
// update an exist account
void updateAccount(Account account);
// get all accounts
List<Account> getAllAccounts();Giao diện này quan trọng trong trường hợp bạn muốn chuyển từ SQLite sang hệ quản trị csdl khác như MySQL :| nó sẽ giúp mọi thứ trở nên đơn giản và ít chỉnh sửa code hơn :|Bước tiếp theo là thực thi giao diện ISQLDb, ở phần này không có gì cao siêu, chỉ là mấy câu lệnh SQL đơn giản thôi :| dưới đây là các đoạn thực thi chính:
@Override
public void addEnergy(Energy energy) {
String sql = "INSERT INTO %s(device_id, energy, utc) VALUES(%d, %d, %d)";
sql = String.format(sql, TableInfo.ENERGY_TABLE_NAME,
energy.getDeviceId(), energy.getEnergy(), energy.getUtc());
mQueue.execute(new SQLiteHelper.NonQueryJob(sql)).complete();
}
@Override
public List<Energy> getEnergies(int deviceId) {
String sql = "SELECT * FROM %s WHERE device_id = %d";
sql = String.format(sql, TableInfo.ENERGY_TABLE_NAME, deviceId);
return mQueue.execute(new SQLiteHelper.EnergyQueryJob(sql)).complete();
}
@Override
public List<Energy> getEnergies(int deviceId, int beginUTC, int endUTC) {
String sql = "SELECT * FROM %s WHERE (device_id = %d) AND (utc >= %d AND utc <= %d)";
sql = String.format(sql, TableInfo.ENERGY_TABLE_NAME, deviceId, beginUTC, endUTC);
return mQueue.execute(new SQLiteHelper.EnergyQueryJob(sql)).complete();
}
@Override
public void addDevice(Device newDevice) {
String sql = "INSERT INTO %s(device_id, name) VALUES(%d, %s)";
sql = String.format(sql, TableInfo.DEVICE_TABLE_NAME, newDevice.getId(),
SQLHelper.prepareString(newDevice.getName()));
mQueue.execute(new SQLiteHelper.NonQueryJob(sql));
}
@Override
public Device getDevice(int deviceId) {
String sql = "SELECT * FROM %s WHERE device_id = %d LIMIT 1";
sql = String.format(sql, TableInfo.DEVICE_TABLE_NAME, deviceId);
List<Device> devices = mQueue.execute(new SQLiteHelper.DeviceQueryJob(sql)).complete();
return devices != null && !devices.isEmpty() ? devices.get(0) : null;
}
@Override
public List<Device> getAllDevices() {
String sql = "SELECT * FROM %s";
sql = String.format(sql, TableInfo.DEVICE_TABLE_NAME);
return mQueue.execute(new SQLiteHelper.DeviceQueryJob(sql)).complete();
}
@Override
public void updateDevice(Device device) {
String sql = "UPDATE %s SET name = %s WHERE device_id = %d";
sql = String.format(sql, TableInfo.DEVICE_TABLE_NAME,
SQLHelper.prepareString(device.getName()), device.getId());
mQueue.execute(new SQLiteHelper.NonQueryJob(sql));
}
@Override
public void addAccount(Account account) {
String sql = "INSERT INTO %s(username, password_hash) VALUES(%s, %s)";
sql = String.format(sql, TableInfo.ACCOUNT_TABLE_NAME,
SQLHelper.prepareString(account.getUserName()),
SQLHelper.prepareString(account.getPasswordHash()));
mQueue.execute(new SQLiteHelper.NonQueryJob(sql)).complete();
}
@Override
public Account getAccount(String username) {
String sql = "SELECT * FROM %s WHERE username = %s";
sql = String.format(sql, TableInfo.ACCOUNT_TABLE_NAME, SQLHelper.prepareString(username));
List<Account> accounts = mQueue.execute(new SQLiteHelper.AccountQueryJob(sql)).complete();
return accounts != null && !accounts.isEmpty() ? accounts.get(0) : null;
}
@Override
public void updateAccount(Account account) {
String sql = "UPDATE %s SET password_hash = %s WHERE id = %d";
sql = String.format(sql, TableInfo.ACCOUNT_TABLE_NAME,
SQLHelper.prepareString(account.getPasswordHash()),
account.getId());
mQueue.execute(new SQLiteHelper.NonQueryJob(sql));
}
@Override
public void removeAccount(int id) {
String sql = "DELETE FROM %s WHERE id = %d";
sql = String.format(sql, TableInfo.ACCOUNT_TABLE_NAME, id);
mQueue.execute(new SQLiteHelper.NonQueryJob(sql));
}
@Override
public List<Account> getAllAccounts() {
String sql = "SELECT * FROM %s";
sql = String.format(sql, TableInfo.ACCOUNT_TABLE_NAME);
return mQueue.execute(new SQLiteHelper.AccountQueryJob(sql)).complete();
}1. TableInfo: là lớp lưu trữ thông tin của các bảng trong csdl bao gồm tên bảng và cấu trúc bảng.
2. mQueue.execute(…).complete(): Vì thư viện SQLite chúng ta đang dùng hổ trợ đa luồng nên để tránh xung đột thì mọi truy vấn đều phải đưa vào 1 hàng đợi riêng SQLiteQueue, phương thức complete() sẽ thực thi truy vấn của chúng ta và trả về kết qủa(kết qủa là gì thì phụ thuộc vào lớp kế thừa từ SQLiteJob class)
3. SQLiteHelper.NonQueryJob, SQLiteHelper.DeviceQueryJob và SQLiteHelper.EnergyQueryJob, SQLiteHelper.AccountQueryJob: đây là 4 lớp mình xây dựng được kế thừa từ SQLiteJob, nó sẽ định nghĩa cụ thể cách thức truy vấn và xử lý dữ liệu trả về…Thực ra thì không cần tụi này cũng được thôi, viết hết vô lớp SQLiteDb luôn cũng chạy tốt cơ nhìn nhứt mắt lắm :|
4. SQLHelper.prepareString(…): phương thức này xử lý chuổi string cần lưu để đảm bảo sẽ lưu được các chuổi string đặt biệt vd như chuổi Son”s, dấu ” là cả vấn đề!
Tạo thêm 1 lớp TemporaryObject trong DAO, nhiệm vụ của nó đơn giản là lưu các real time value vào list trong bộ nhớ.
public final class TemporaryObject {
private List<RealTime> data;
public void clear() {
data.clear();
}
public RealTime get(int deviceId) {
for (int i = 0; i < data.size(); i++) {
if (data.get(i).getDeviceId() == deviceId) {
return data.get(i);
}
}
return null;
}
public void add(RealTime rt) {
data.add(rt);
}
public boolean exists(int deviceId) {
for (int i = 0; i < data.size(); i++) {
if (data.get(i).getDeviceId() == deviceId) {
return true;
}
}
return false;
}
public void update(RealTime rt) {
for (int i = 0; i < data.size(); i++) {
if (data.get(i).getDeviceId() == rt.getDeviceId()) {
data.set(i, rt);
}
}
}
public TemporaryObject() {
data = new ArrayList<>();
}
}Xây dựng các lớp quản lý cấu hình
DAO của Model đã hoàn tất, trước khi xử phần BO ta xây dựng 1 số lớp quản lý cấu hình. Đầu tiên ta tạo thêm 3 lớp Convert(shared), Config(web) và ConfigLoader(web) trong package utils:Chức năng của chúng như sau:Ta định nghĩa ConfigLoader như bên dưới:
1. Convert: sẽ chứa các phương thức chuyển đổi dữ liệu.
2. Config: chứa các dữ liệu cấu hình của web service.
3. ConfigLoader: hổ trợ cho Config class, nhiệm vụ chính là để nạp cấu hình từ file.
public class ConfigLoader {
// chứa các key và gía trị mặt định của các cấu hình
public static final String[][] DATA_MAP = {
{ "dbname", "local.db" },
{ "address", "127.0.0.1" },
{ "port", "2512" },
{ "timeout", "10000" },
{ "relay-get-realtime", "2000" },
{ "relay-get-energy", "10000" },
{ "su-username", "admin"},
{ "su-password", "admin"}};
// dấu phân tách giữa key và value
private static final char DELIM = '=';
private final HashMap<String, String> map;
private final File file;
// lấy dữ liệu thực từ file cấu hình
public String get(int index) {
String key = DATA_MAP[index][0];
String value = map.get(key);
return value != null ? value : DATA_MAP[index][1];
}
// tạo ra file cấu hình nếu nó chưa tồn tại :|
public boolean create() {
BufferedWriter writer = null;
try {
writer = new BufferedWriter(new FileWriter(file));
for (int i = 0; i < DATA_MAP.length; i++) {
String line = String.format("%s%c%s\n", DATA_MAP[i][0], DELIM, DATA_MAP[i][1]);
writer.write(line);
}
return true;
} catch (IOException e) {
e.printStackTrace();
return false;
} finally {
if (writer != null) {
try {
writer.close();
} catch (IOException e) {
}
}
}
}
// nạp nội dung file cấu hình vào hash map
public boolean load() {
if (!file.exists())
return false;
BufferedReader reader = null;
try {
reader = new BufferedReader(new FileReader(file));
while (reader.ready()) {
String line = reader.readLine();
String key = line.substring(0, line.indexOf(DELIM));
String value = line.substring(key.length()).trim();
map.put(key, value);
}
return true;
} catch (IOException ex) {
ex.printStackTrace();
return false;
} finally {
if (reader != null) {
try {
reader.close();
} catch (IOException e) {
}
}
}
}
public ConfigLoader(String configFile) {
map = new HashMap<String, String>();
file = new File(configFile);
}
}File cấu hình ở đây có cấu trúc gồm từng dòng, mỗi dòng tương ứng với 1 loại cấu hình. Trong mỗi dòng gồm 2 phần là key và value, ví dụ như sau:Trong Config class ta định nghĩa các trường cấu hình như sau:
address=192.168.1.111
port=2512
dbname=mydata.db
// thư mục làm việc chính của ta, nơi lưu dữ liệu, file cầu hình blabla. các bạn có thể thay đổi gía trị của nó sang 1 địa chỉ bất kỳ để dể debug
public static final String WORKING_DIR;
// tên file cấu hình
public static final String CONFIG_FILE_NAME;
// đường đẩn tới file csdl
public static final String DB_PATH;
// địa chỉ nơi mà server sẽ lắng nghe các kết nối từ device
public static final String SERVER_ADDRESS;
// port server dùng để lắng nghe kết nối từ device
public static final int SERVER_PORT;
// timeout khi truyền nhận dữ liệu
public static final int DATA_IN_TIMEOUT;
// thời gian trì hoản giữa các lần lấy gía trị real time từ device
public static final int RELAY_GET_REALTIME;
// thời gian trì hoản giuwax các lần lấy gía trị energy từ device
public static final int RELAY_GET_ENERGY;
// tên đăng nhập của superuser
public static final String SU_USERNAME;
// mật khẩu plaintext của superuser
public static final String SU_PASSWORD;static {
// WORKING_DIR = "/home/noem" --> debug in linux
// WORKING_DIR = "c:/Users/noem" --> debug in windows
// WORKING_DIR = any folder which you want :|
// theo cấu hình thư mục làm việc như bên dưới thì nó sẽ nằm ở ngay thư mục của web service khi được deploy, khi debug với eclipse thì các bạn nên thay đổi nó sang 1 địa chỉ dể nhớ như ổ C chẳng hạn
WORKING_DIR = System.getProperty("catalina.base") + "/webapps/MyWS";
CONFIG_FILE_NAME = WORKING_DIR + "/config.in";
ConfigLoader loader = new ConfigLoader(CONFIG_FILE_NAME);
if (!loader.load()) {
if (!loader.create()) {
System.err.println("System can't create file in " + CONFIG_FILE_NAME);
System.exit(1);
}
}
DB_PATH = WORKING_DIR + "/" + loader.get(0);
SERVER_ADDRESS = loader.get(1);
SERVER_PORT = Convert.parseInt(loader.get(2), 2512);
DATA_IN_TIMEOUT = Convert.parseInt(loader.get(3), 10000);
RELAY_GET_REALTIME = Convert.parseInt(loader.get(4), 2000);
RELAY_GET_ENERGY = Convert.parseInt(loader.get(5), 10000);
SU_USERNAME = loader.get(6);
SU_PASSWORD = loader.get(7);
}Chú ý rằng server sẽ làm việc với các thiết bị 1 cách chủ động, nghĩa là nó sẽ gửi yêu cầu đến thiết bị và sau đó thiết bị gửi dữ liệu phản hồi. Ví dụ server muốn lấy gía trị real-time thì nó sẽ gửi gói tin yêu cầu lấy real-time cho device sau đó thiết bị sẽ gửi lại gía trị real-time cho server.
Xây dựng BO của Model
Bây giờ ta code tiếp phần BO, tạo class SQLMgr trong package bo, lớp này sẽ xử lý vấn đề logic trước khi đẩy dữ liệu xuống hoặc lấy dữ liệu tên từ DAO. Một số phương thức chính như sau:public void addEnergy(Energy energy) {
if (energy != null && energy.getDeviceId() > 0 && energy.getEnergy() > 0 && energy.getUtc() > 0)
mSQLDb.addEnergy(energy);
}
public List<Energy> getEnergies(int deviceId) {
return deviceId > 0 ? mSQLDb.getEnergies(deviceId) : null;
}
private List<Energy> getEnergies(int deviceId, DateTime begin, DateTime end) {
int beginUTC = begin.toInteger();
int endUTC = end.toInteger();
return mSQLDb.getEnergies(deviceId, beginUTC, endUTC);
}
public float[] getEnergies(int deviceId, int year) {
DateTime begin = new DateTime(1, 1, year, 0, 0, 0);
DateTime end = new DateTime(31, 12, year, 23, 59, 59);
List<Energy> energies = getEnergies(deviceId, begin, end);
return energies != null ? Convert.getEnergyGroupByMonths(energies, year) : null;
}
public float[] getEnergies(int deviceId, int month, int year) {
if (deviceId <= 0 || year < 2015 || month < 1 || month > 12)
return null;
DateTime begin = new DateTime(1, month, year, 0, 0, 0);
DateTime end = new DateTime(DateTime.getMaxDay(month, year), month, year, 23, 59, 59);
List<Energy> energies = getEnergies(deviceId, begin, end);
return energies != null ? Convert.getEnergyGroupByDays(energies, month, year) : null;
}
public float[] getEnergies(int deviceId, int day, int month, int year) {
if (deviceId <= 0 || year < 2015 || month < 1 || month > 12 || day < 0 || day > DateTime.getMaxDay(month, year))
return null;
DateTime begin = new DateTime(day, month, year, 0, 0, 0);
DateTime end = new DateTime(day, month, year, 23, 59, 59);
List<Energy> energies = getEnergies(deviceId, begin, end);
return energies != null ? Convert.getEnergyGroupBy24h(energies, day, month, year) : null;
}
private void validDeviceInfo(Device device) {
if (device.getName() != null) {
String name = device.getName().trim();
if (name.length() == 0)
name = "Unknown";
else if (name.length() > 25)
name.substring(0, 25);
name = name.replace(' ', '-');
device.setName(name);
}
}
public void addDevice(Device newDevice) {
if (newDevice.getId() > 0 && newDevice.getName() != null) {
validDeviceInfo(newDevice);
mSQLDb.addDevice(newDevice);
}
}
public Device getDevice(int deviceId) {
return deviceId > 0 ? mSQLDb.getDevice(deviceId) : null;
}
public List<Device> getAllDevices() {
return mSQLDb.getAllDevices();
}
public void updateDevice(Device device) {
if (device.getId() > 0 && device.getName() != null) {
validDeviceInfo(device);
mSQLDb.updateDevice(device);
}
}
public boolean addAccount(Account account) {
if (account.getUserName() != null && account.getPasswordHash() != null) {
if (!Account.checkUserName(account.getUserName()))
return false;
if (account.getPasswordHash().length() == 0)
return false;
mSQLDb.addAccount(account);
return true;
}
return false;
}
public boolean checkLogin(String username, String passwordHash) {
Account account = getAccount(username);
if (account == null)
return false;
return account.getPasswordHash().compareToIgnoreCase(passwordHash) == 0;
}
public Account getAccount(String username) {
return (username == null || !Account.checkUserName(username)) ? null : mSQLDb.getAccount(username);
}
public void updateAccount(Account account) {
if (account.getId() > 0 && account.getPasswordHash() != null) {
if (account.getPasswordHash().length() > 0)
mSQLDb.updateAccount(account);
}
}
public void deleteAccount(int id) {
if (id > -1)
mSQLDb.removeAccount(id);
}
public List<Account> getAllAccounts() {
return mSQLDb.getAllAccounts();
}Ở đây có 4 thứ cần chú ý:Tiếp theo ta thêm 1 lớp nữa là TemporaryManager trong BO, nhiệm vụ cửa lớp này là xử lý logic trước khi gọi TemporaryObject. Các phương thức chính như sau:
1. DateTime class, lớp này mình viết sẳn để dùng cho tiện, tại hiện tại chỉ cần quan tâm đến chức năng convert từ DateTime tới gía trị int và ngược lại được định nghĩa sẳn trong class.
2. Account.checkUserName, phương thức static checkUserName trong class Account dùng để kiểm tra xem user name có hợp lệ không.
3. mSQLDb là thuộc tính kiểu giao diện ISQLDb, ở đây nó là mSQLDb = new SQLiteDb(Config.DB_PATH);
4. Convert.getEnergyGroupBy…: Phương thức này sẽ nhóm các dữ liệu điện năng thành các gía trị float theo thời gian. Ở đây có nhóm theo 24h, theo ngaỳ và theo tháng.
// phương thức này sẽ reset các gía trị tạm của 1 thiết bị, dùng trường hợp thiết bị ngắt kết nối với server
public void off(int deviceId) {
if (deviceId > 0) {
RealTime realTime = temporaryObject.get(deviceId);
if (realTime != null) {
realTime.setAmperage(0);
realTime.setPower(0);
realTime.setVoltage((short) 0);
realTime.setState((byte) 0);// 0 - OFF, else ON :|
}
}
}
// lấy thông tin real time của 1 thiết bị
public RealTime get(int deviceId) {
return deviceId > 0 ? temporaryObject.get(deviceId) : null;
}
// lưu thông tin real time của 1 thiết bị(thêm mới nếu chưa có trong list hoặc cập nhật nếu đã có)
public void set(RealTime realTime) {
if (realTime != null) {
if (temporaryObject.exists(realTime.getDeviceId()))
temporaryObject.update(realTime);
else
temporaryObject.add(realTime);
}
}Các lớp trợ giúp truyền nhận dữ liệu
Cần chuẩn bị một số thứ trước khi xây dựng controller, trong shared làm 1 số công việc sau:Tạo TransmissionObject class: nhiệm vụ của nó là chứa dữ liệu phản hồi mà client yêu cầu và tình trạng của yêu cầu(như yêu cầu thành công, yêu cầu thất bại do lỗi login…).
// lỗi login
public static final int CODE_AUTH_ERR = 1;
// yêu cầu thành công
public static final int CODE_DATA_OK = 2;
// ko tìm thấy dữ liệu đã yêu cầu :|
public static final int CODE_DATA_NULL = 3;
private int code;// chứa tình trạng của yêu cầu
private Object data;// dữ liệu chính mà client yêu cầuỞ đây ta có 1 số quy ước, mỗi lần client gửi yêu cầu đến server đều phải kèm theo thông tin login, nghĩa là mỗi yêu cầu đều phải được xác thực trước khi thực hiện. Thực ra điều này là không cần thiết nếu bạn truy cập từ trình duyệt vì nó hổ trợ session nghĩa là chỉ cần login lần đầu. Lý do ta phải xác thực mỗi lần gửi yêu cầu đến server là vì lớp HttpURLConnection của app android không hổ trợ session nghĩa là nó đơn giản là gửi yêu cầu đến web service rồi nhận lại phản hồi, do đó ta không thể biết được yêu cầu đó đã login chưa. Dĩ nhiên là có cách để lưu lại lịch sử đăng nhập để tránh tình trạng phải login lại mỗi lần gửi yêu cầu nhưng ở bài viết này mình chỉ làm theo cách này cho nhanh.Thêm 2 phương thức cho Convert class giúp chuyển đổi 1 object thành mảng bytes và ngược lại nhờ đó ta có thể truyền các objects từ server tới client:
// chuyển đổi 1 object thành mảng bytes, object phải thực thi giao diện Serializable
public static byte[] objectToBytes(Object obj) {
ByteArrayOutputStream baos = null;
ObjectOutputStream oos = null;
try {
baos = new ByteArrayOutputStream();
oos = new ObjectOutputStream(baos);
oos.writeObject(obj);
byte[] ret = baos.toByteArray();
return ret;
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if (baos != null)
baos.close();
if (oos != null)
oos.close();
} catch (IOException e) {
}
}
return null;
}
// chuyển đổi mảng bytes được tạo ra từ phương thức objectToBytes(...) thành object
public static Object bytesToObject(byte[] bytes) {
ByteArrayInputStream bais = null;
ObjectInputStream ois = null;
try {
bais = new ByteArrayInputStream(bytes);
ois = new ObjectInputStream(bais);
Object obj = ois.readObject();
return obj;
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (bais != null)
bais.close();
if (ois != null)
ois.close();
} catch (IOException e) {
}
}
return null;
}Thực ra đây chỉ là 1 cách convert dữ liệu để truyền đi qua mạng, bạn có thể dùng JSON, xml hoặc thậm chỉ là parse từ trang jsp(nếu làm cách này nghĩa là bạn sẽ hổ trợ trực tiếp truy cập thông qua trình duyệt và bên app chỉ cần lấy nội dung trang web sau đó parse để lấy dữ liệu). Vì cách convert ra bytes và sau đó từ bytes convert ngược lại đơn giản chỉ cần thông qua 2 phương thức trên nên mình dùng cách này cho tiện.Tạo IDataConvert interface, định nghĩa giao diện convert dữ liệu để gửi từ server tới client và convert dữ liệu đã nhận từ server ở client.
public interface IDataConvert {
// convert objects để gửi cho client
byte[] encode(Object in);
// lấy objects đã từ server ở client
Object decode(byte[] in);
}Giao diện này cũng tương tự như ISQLDb, nó giúp việc chuyển đổi từ các cách thức convert dữ liệu 1 cách dể dàng. Ngoài cách convert kiểu bytes ra ta còn convert kiểu text như xml chẳng hạn nhưng mình định nghĩa giao diện bên trên sử dụng kiểu bytes vì đơn giản text chỉ là mảng bytes :|Tạo SerialConvert class thực thi giao diện IDataConvert bên trên, mình định nghĩa 1 sample convert dữ liệu sử dụng cách thức serial của java. Bạn có thể tạo 1 XmlConvert, JSONConvert hoặc blablaConvert thực thi từ IDataConvert để convert dữ liệu theo cách riêng của bạn. Nỗi dung của class này:
public final class SerialConvert implements IDataConvert {
private static SerialConvert instance = null;
public static SerialConvert getInstance() {
if (instance == null)
instance = new SerialConvert();
return instance;
}
private SerialConvert() {
}
@Override
public byte[] encode(Object in) {
return in != null ? Convert.objectToBytes(in) : null;
}
@Override
public Object decode(byte[] in) {
return in != null ? Convert.bytesToObject(in) : null;
}
}Thực ra ở đây cũng không cần dùng single-ton, cơ mà viết xong class này rồi mới chộ ra nên để vậy luôn tại lười xóa qúa :|Finally, tạo CrossFlatform class, dùng để convert dữ liệu để gửi đi qua mạng. Nếu bạn muốn sử dụng xml hoặc json hoặc blabla để convert dữ liệu thì chỉ cần làm 2 việc là tạo ra 1 class thực thi từ IDataConvert và thay thế gía trị của trường dataConvert bên dưới thành instance của class bạn vừa tạo :| nói thì dài dòng nhưng làm thì cũng nhanh thôi.
private static IDataConvert dataConvert = SerialConvert.getInstance();
public static byte[] toBytes(TransmissionObject obj) {
return dataConvert.encode(obj);
}
public static TransmissionObject fromBytes(byte[] bytes) {
Object obj = dataConvert.decode(bytes);
if (obj == null || !(obj instanceof TransmissionObject))
return null;
return (TransmissionObject) obj;
}Phương thức toBytes dùng ở server còn fromBytes dùng ở client.
Lớp quản lý kết nối và điều khiển thiết bị
Đầu tiên ta xây dựng giao thức truyền nhận dữ liệu giữa thiết bị và server. Cấu trúc gói tin của ta như sau:Package: start[1] length[1] data[n] checksum[1] stop[1]
start: 1 byte, đánh dấu bắt đầu gói tin
length: 1 byte, chiều dài dữ liệu(data)
data: n bytes, dữ liệu chính cần truyền đi
checksum: 1 byte, kiểm tra sai lệch dữ liệu, ở đây ta dùng mã vòng crc
stop: 1 byte, đánh dấu kết thúc gói tin
- Phía server sẽ yêu cầu lấy id của thiết bị.`a
- Sau khi lấy được id của thiết bị, server tiến hành kiểm tra xem id đó đã có trong csdl chưa, nếu chưa thì nó sẽ thêm mới vào csdl.
- Phía server sẽ bắt đầu vòng lặp gửi yêu cầu lấy thông tin điện năng và thông tin real-time sau 1 khoản thời gian xác định, các yêu cầu này đều nằm trong 1 hàng đợi. Thông tin điện năng sẽ được lưu trữ vào csdl, thông tin real-time sẽ được lưu vào bộ nhớ tạm. Vòng lặp kết thúc chỉ khi thiết bị ngắt kết nối tới server.
- Khi vòng lặp chính ở bước 3 chưa kết thúc, ta có thể yêu cầu điều khiển thiết bị từ app bằng cách gửi yêu cầu đến server, lúc này server sẽ đưa yêu cầu của ta vào 1 hàng đợi công việc để thực thi.
Đầu tiên ta tạo lớp Protocol làm nhiệm vụ quy định giao thức liên lạc giữa thiết bị. Hai phương thức chính như sau:
// đọc phần data của gói tin, phương thức sẽ chờ cho đến khi có dữ liệu trong 1 khoản timeout nhất định.
public byte[] readData() {
// chờ đến khi có dữ liệu trong 1 khoản timeout cố định
if (!waitForAvailable())
return null;// hết timeout mà vẩn chưa có dữ liệu
try {
boolean start = false;
int length = -1;
byte[] data = new byte[DATA_IN_BUFFER_SIZE];
int index = 0;
byte crc = -1;
boolean crcOK = false;
boolean stop = false;
// đọc gói tin, nếu dữ liệu của gói tin có vấn đề thì nó sẻ restart lại giao thức
while (true) {
if (in.available() < 1 && !waitForAvailable())
break;
int b = in.read();
if (b == -1)
break;
// đọc byte start
if (!start) {
if (b == FLAG_BYTE_START)
start = true;
continue;
}
// đọc byte chiều dài của data
if (length < 0) {
length = b;
if (length < 1)
start = false;// restart protocol
continue;
}
// đọc phần data chính
if (index < length) {
data[index++] = (byte) b;
continue;
}
// đọc checksum crc
if (!crcOK) {
crc = (byte) b;
crcOK = true;
continue;
}
// đọc byte stop
if (b == FLAG_BYTE_STOP) {
stop = true;
break;
} else {
start = false;// failed protocol, restart protocol
}
}
// check result
if (stop) {
// checksum crc
byte checkCRC = crc8(data, 0, length);
if (checkCRC == crc) {
byte[] buff = new byte[length];
System.arraycopy(data, 0, buff, 0, length);
return buff;// everything is OK
}
}
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
// nhiệm vụ của nó là gửi phần dữ liệu chính đến thiết bị bằng cách tạo ra 1 gói tin rồi nhét data vô sau đó send đi :|
public boolean writeData(byte[] data) {
// create package to hold actual data when send to remote
byte[] buff = new byte[4 + data.length];// start + length + checksum + stop = 4 bytes :|
int offset = 0;
// init start byte
buff[offset++] = FLAG_BYTE_START;
// init data length
buff[offset++] = (byte) data.length;
// init actual data
System.arraycopy(data, 0, buff, offset, data.length);
offset += data.length;
// init checksum crc
buff[offset++] = crc8(data, 0, data.length);
// init stop byte
buff[offset] = FLAG_BYTE_STOP;
// now! send package to remote
try {
out.write(buff);
return true;
} catch (IOException e) {
e.printStackTrace();
}
return false;
}public abstract class BaseJob {
// chu kỳ lặp lại của 1 công việc, nó chỉ cần thiết với các công việc cần thực hiện lặp đi lặp lại như lấy điện năng chẳng hạn
private final int initWaitTime;
private int currentWaitTime = 0;
// giao thức quy định cách giao tiếp với thiết bị
protected final Protocol protocol;
// thực chất là id của thiết bị
protected final int clientId;
// quy định cách xử lý khi nhận được dữ liệu phản hồi từ thiết bị
protected final IJobExecutor executor;
// reset lại công việc
public void reset() {
currentWaitTime = initWaitTime;
}
// kiểm tra xem công việc có thể thực hiện được chưa đồng thời giảm thời gian chờ
public boolean checkAndReduce(int milis) {
boolean canExecute = currentWaitTime <= 0;
currentWaitTime -= milis;
return canExecute;
}
// thực hiện công việc, tùy vào từng loại công việc mà định nghĩa khác nhau. trả về true nếu thực hiện thành công và false nếu thất bại.
public abstract boolean execute();
// kiểm tra xem công việc này có thể sử dụng lại được không
public abstract boolean canReused();
public BaseJob(IJobExecutor executor, int clientId, int waitTime, Protocol protocol) {
this.executor = executor;
this.clientId = clientId;
initWaitTime = waitTime;
currentWaitTime = waitTime;
this.protocol = protocol;
}
}// khi client nhận được id của thiết bị gửi đến
void onHasId(int deviceId);
// khi client nhận được thông tin điện năng
void onHasEnergy(Energy energy);
// khi client nhận được thông tin real-time
void onHasRealTime(RealTime realtime);
// khi thiết bị ngắt kết nối
void onDisconnected(int deviceId);// định nghĩa công việc lấy id của thiết bị, ManagerJob định nghĩa các công việc không thể reused, thực ra thì cho IdJob kế thừa trực tiếp từ BaseJob cũng được.
public class IdJob extends ManagerJob {
public IdJob(IJobExecutor executor, Protocol protocol) {
super(executor, protocol);
}
@Override
public boolean execute() {
// gửi yêu cầu cho thiết bị
if (protocol.request(Protocol.TYPE_ID)) {
// yêu cầu gửi thành công, giờ nó sẽ nhận lại dữ liệu phản hồi từ thiết bị
byte[] data = protocol.readData();
// chuyển đổi bytes đã nhận ra id của thiết bị
int id = Protocol.parseInt(data, Protocol.TYPE_ID);
if (id < 0)
return false;
// thực thi tác vụ đã định nghĩa trong IJobExecutor khi đã nhận được id
executor.onHasId(id);
return true;
} else {
return false;
}
}
}// định nghĩa công việc lấy thông tin điện năng của thiết bị. lớp MonitorJob mô tả công việc có thể reused, thực ra thì bạn hoàn toàn có thể kế thừa trực tiếp từ BaseJob.
public class EnergyJob extends MonitorJob {
public EnergyJob(IJobExecutor executor, int clientId, int waitTime, Protocol protocol) {
super(executor, clientId, waitTime, protocol);
}
@Override
public boolean execute() {
// gửi yêu cầu lấy thông tin điện năng
if (protocol.request(Protocol.TYPE_ENERGY)) {
// lấy dữ liệu phản hồi từ thiết bị
byte[] data = protocol.readData();
// chuyển bytes dữ liệu thành gía trị điện năng
int energyValue = Protocol.parseInt(data, Protocol.TYPE_ENERGY);
if (energyValue < 0)
return false;
// tạo thực thể Energy với các thông tin như id thiết bị, gía trị điện năng và thời gian nhận
Energy energy = new Energy();
energy.setDeviceId(clientId);
energy.setEnergy(energyValue);
energy.setUtc(DateTime.now().toInteger());
// thực thi tác vụ đã định nghĩa trong IJobExecutor khi nhận được thông tin điện năng
executor.onHasEnergy(energy);
return true;
} else {
return false;
}
}
}// khơi tạo hàng đợi với 2 công việc mặt định là lấy thông tin điện năng và real-time
private void initJobQueue() {
EnergyJob energyJob = new EnergyJob(executor, clientId, timewaitEnergy, protocol);
RealTimeJob realTimeJob = new RealTimeJob(executor, clientId, timewaitRealtime, protocol);
jobs.add(energyJob);
jobs.add(realTimeJob);
}
// bắt đầu hàng đợi công việc
private void startJobQueue() {
boolean crashConnection = false;
boolean interrupted = false;
penddingStop = false;
// lặp đi lặp lại các công việc cho đến khi có server yêu cầu ngừng hoặc có sự cố kết nối.
while (!penddingStop && !crashConnection && !interrupted) {
synchronized (lock) {
for (int i = 0; i < jobs.size(); i++) {
BaseJob job = jobs.get(i);
// kiểm tra xem công việc có thể thực hiện được chưa(vì các công việc như lấy thông tin điện năng đều có chu kỳ thời gian riêng nên phải có bước này)
if (job.checkAndReduce(100)) {
// OK! thực hiện và kiểm tra xem có thành công không
if (!job.execute()) {
crashConnection = true;
break;
} else {
// nếu công việc có thể reused thì reset ngược lại thì xóa khỏi hàng đợi
if (job.canReused())
job.reset();
else
jobs.remove(job);
}
}
}
}
if (!crashConnection) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
interrupted = true;
}
}
}
fireClientStopped();
}
// entry của thread
@Override
public void run() {
// bước đầu tiên ta cần lấy id của thiết bị trước khi bắt đầu làm việc chính thức với nó
BaseJob idJob = new IdJob(new IJobExecutor() {
@Override
public void onHasRealTime(RealTime realtime) {
}
// có id rồi, giờ ta mới khởi tạo và bắt đầu hàng đợi
@Override
public void onHasId(int deviceId) {
executor.onHasId(deviceId);
clientId = deviceId;
initJobQueue();
startJobQueue();
}
@Override
public void onHasEnergy(Energy energy) {
}
@Override
public void onDisconnected(int deviceId) {
}
}, protocol);
if (!idJob.execute()) {
// ko lấy được id thì coi ngắt kết nối, kết thúc phiên làm việc với thiết bị
fireClientStopped();
}
}public final class DeviceManager implements Runnable, OnClientStoppedListener {
private static DeviceManager instance = null;
// việc lắng nghe kết nối sẽ được thực thi ở 1 thread khác
private final Thread worker = new Thread(this);
// ServerSocket để lắng nghe kết nối
private ServerSocket server;
// danh sách các clients
private final List<Client> clients = new ArrayList<Client>();
private final Object lock = new Object();
// quy định các tác vụ cần thực hiện khi nhận được dữ liệu từ thiết bị
private final IJobExecutor executor;
// chu kỳ lấy thông tin điện năng là 1s
private int timewaitEnergy = 1000;
// chu kỳ lấy thông tin real-time là 1s
private int timewaitRealtime = 1000;
// timeout cho việc nhận dữ liệu là 10s
private int timeout = 10000;
......
}Xây dựng Controller
Chuẩn bị đã xong(hi vọng là thế), bây giờ trở lại web service project.Mô hình chúng ta sẽ như thế này:
@WebListener
public class LifecycleListener implements ServletContextListener {
// tự động thực thi webservice stop
public void contextDestroyed(ServletContextEvent arg0) {
SQLMgr.destroyInstance();
TemporaryManager.destroyInstance();
DeviceManager.getInstance().stop();
}
// khởi tạo và bắt đầu DeviceManager
private void initializeDeviceManager() {
// khởi tạo DeviceManager từ các thông tin cấu hình
DeviceManager.createInstance(Config.SERVER_ADDRESS, Config.SERVER_PORT, new JobExecutor());
DeviceManager deviceManager = DeviceManager.getInstance();
deviceManager.setTimeout(Config.DATA_IN_TIMEOUT);
deviceManager.setTimewaitEnergy(Config.RELAY_GET_ENERGY);
deviceManager.setTimewaitRealtime(Config.RELAY_GET_REALTIME);
// bắt đầu lắng nghe các kết nối từ thiết bị
deviceManager.start();
}
// khởi tạo TemporaryManager, nạp các thiết bị trong csdl vô bộ nhớ
private void initializeTemporaryManager() {
List<Device> devices = SQLMgr.getInstance().getAllDevices();
TemporaryManager.createInstance(devices);
}
// tự động thực thi khi webservice start
public void contextInitialized(ServletContextEvent arg0) {
SQLMgr.getInstance();// để ép SQLMgr khởi tạo và kết nối csdl
initializeTemporaryManager();
initializeDeviceManager();
}
}public class JobExecutor implements IJobExecutor {
// khi nhận được id nghĩa là 1 thiết bị vừa kết nối với server, lúc này ta kiểm tra xem thiết bị đó đã có trong csdl chưa, nếu chưa có thì lưu vô csdl.
@Override
public void onHasId(int deviceId) {
Device device = SQLMgr.getInstance().getDevice(deviceId);
if (device == null && deviceId > 0) {
device = new Device();
device.setId(deviceId);
device.setName("Unknown");
SQLMgr.getInstance().addDevice(device);
}
}
// lưu thông tin điện năng vào csdl
@Override
public void onHasEnergy(Energy energy) {
SQLMgr.getInstance().addEnergy(energy);
}
// lưu real-time vào bộ nhớ
@Override
public void onHasRealTime(RealTime realtime) {
TemporaryManager.getInstance().set(realtime);
}
// reset thông tin real-time của thiết bị trong bộ nhớ
@Override
public void onDisconnected(int deviceId) {
TemporaryManager.getInstance().off(deviceId);
}
}| Tên | Các chức năng |
|---|---|
| AccountServlet | Kiểm tra login, thay đổi mật khẩu |
| DeviceServlet | Lấy thông tin 1 hoặc tất cả thiết bị, đổi tên hoặc bật tắt thiết bị |
| EnergyServlet | Lấy thông tin điện năng của 1 thiết bị trong ngày, tháng, năm hoặc toàn bộ |
| RealTimeServlet | Lấy thông tin real-time của 1 thiết bị |
// các servlet kế thừa từ BaseServlet sẽ phải thực thi phương thức này, khi phương thức này được gọi nghĩa là việc login đã thành công và giờ chỉ việc xử lý yêu cầu người dùng nữa thôi
protected abstract void doWork(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException;
// lấy id của thiết bị, sẽ dùng ở 1 số subclass
protected int getDeviceId(HttpServletRequest request) {
return Convert.parseInt(request.getParameter("id"), -1);
}
// gửi phản hồi lại cho client
protected void doResp(Object data, HttpServletResponse resp) throws IOException {
TransmissionObject obj = new TransmissionObject();
obj.setCode(data != null ? TransmissionObject.CODE_DATA_OK : TransmissionObject.CODE_DATA_NULL);
obj.setData(data);
resp.getOutputStream().write(CrossFlatform.toBytes(obj));
}
// tự động gửi phản hồi login fail :|
private void responseAuthenticationError(HttpServletResponse response) throws IOException {
TransmissionObject obj = new TransmissionObject();
obj.setCode(TransmissionObject.CODE_AUTH_ERR);
response.getOutputStream().write(CrossFlatform.toBytes(obj));
}
// xử lý yêu cầu login và gọi doWork, chú ý rằng phương thức doGet và doPost đều được đánh dấu là final để đảm bảo rằng các servlet con kế thừa từ BaseServlet sẽ chỉ thực thi yêu cầu(doWork(...)) khi login thành công!
@Override
protected final void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
String username = request.getParameter("username");
String passwordHash = request.getParameter("passhash");
if (username == null || passwordHash == null) {
responseAuthenticationError(response);
} else if (!SQLMgr.getInstance().checkLogin(username, passwordHash)) {
responseAuthenticationError(response);
} else {
doWork(request, response);
}
}// lấy thông tin 1 thiết bị bởi id của nó
private Object responseDevice(HttpServletRequest request) {
int deviceId = getDeviceId(request);
return SQLMgr.getInstance().getDevice(deviceId);
}
// lấy toàn bộ thiết bị có trong csdl
private Object responseAllDevices() {
return SQLMgr.getInstance().getAllDevices();
}
// đổi tên thiết bị
private Object responseUpdate(HttpServletRequest request) {
int deviceId = getDeviceId(request);
String newName = request.getParameter("newname");
Device device = new Device();
device.setId(deviceId);
device.setName(newName);
SQLMgr.getInstance().updateDevice(device);
return "OK";
}
// bật tắt thiết bị, nếu thiết bị chưa kết nối đến server thì kết quả là sai
private Object responseTurn(HttpServletRequest request) {
int deviceId = getDeviceId(request);
int off = Convert.parseInt(request.getParameter("off"), 1);
Client client = DeviceManager.getInstance().getClientById(deviceId);
if (client != null) {
if (off != 0)
client.turnOff();
else
client.turnOn();
return "OK";
}
return "FAIL";
}
@Override
protected void doWork(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
String req = request.getParameter("req");
if (req == null)
return;
Object data = null;
switch (req) {
case "single":
data = responseDevice(request);
break;
case "all":
data = responseAllDevices();
break;
case "rename":
data = responseUpdate(request);
break;
case "turn":
data = responseTurn(request);
break;
}
doResp(data, response);
}// điện năng của ngày
private Object responseDay(HttpServletRequest request) {
int day = Convert.parseInt(request.getParameter("day"), -1);
int month = Convert.parseInt(request.getParameter("month"), -1);
int year = Convert.parseInt(request.getParameter("year"), -1);
return SQLMgr.getInstance().getEnergies(getDeviceId(request), day, month, year);
}
// điện năng của tháng
private Object responseMonth(HttpServletRequest request) {
int month = Convert.parseInt(request.getParameter("month"), -1);
int year = Convert.parseInt(request.getParameter("year"), -1);
return SQLMgr.getInstance().getEnergies(getDeviceId(request), month, year);
}
// điện năng của năm
private Object responseYear(HttpServletRequest request) {
int year = Convert.parseInt(request.getParameter("year"), -1);
return SQLMgr.getInstance().getEnergies(getDeviceId(request), year);
}
// toàn bộ điện năng
private Object responseAll(HttpServletRequest request) {
return SQLMgr.getInstance().getEnergies(getDeviceId(request));
}
@Override
protected void doWork(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
String req = request.getParameter("req");
if (req == null)
return;
Object data = null;
switch (req) {
// lấy điện năng tiêu thụ trong 1 ngày
// req=day&id=102120250&day=25&month=12&year=2015
case "day":
data = responseDay(request);
break;
// lấy điện năng tiêu thụ trong 1 tháng
// req=month&id=102120250&month=12&year=2015
case "month":
data = responseMonth(request);
break;
// lấy điện năng tiêu thụ trong 1 năm
// req=year&id=102120250&year=2015
case "year":
data = responseYear(request);
break;
// lấy toàn bộ điện năng của thiết bị
// req=year&id=102120250
case "all":
data = responseAll(request);
break;
}
doResp(data, response);
}@Override
protected void doWork(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
int deviceId = getDeviceId(request);
doResp(TemporaryManager.getInstance().get(deviceId), response);
}// kiểm tra login
private Object responseCheckLogin(HttpServletRequest request) {
String username = request.getParameter("username");
Account account = SQLMgr.getInstance().getAccount(username);
return account;
}
// thay đổi mật khẩu người dùng
private Object responseChangePasswordHash(HttpServletRequest request) {
String username = request.getParameter("username");
String newPasswordHash = request.getParameter("npasshash");
int userid = Convert.parseInt(request.getParameter("userid"), -1);
Account account = new Account();
account.setId(userid);
account.setUserName(username);
account.setPasswordHash(newPasswordHash);
SQLMgr.getInstance().updateAccount(account);
return "OK";
}
@Override
protected void doWork(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
String req = request.getParameter("req");
if (req == null)
return;
Object data = null;
switch (req) {
case "check":
data = responseCheckLogin(request);
break;
case "changepass":
data = responseChangePasswordHash(request);
break;
}
doResp(data, response);
}Quản lý người dùng
Phần này khá hay ho, ý tưởng thế này: mỗi người dùng bình thường sẽ có 1 tài khoản và mật khẩu để được sử dụng tài nguyên của web service và như thế là sẽ có nhiều người dùng trong hệ thống và thông tin mỗi người dùng sẽ được lưu trong csdl. Để quản lý những người dùng đó(như xóa hoặc thêm người dùng mới) ta định nghĩa một super-user(nếu các bạn đọc các đoạn code bên trên thì sẽ thấy 1 số chổ hơi kỳ lạ đó là trường SU_USERNAME, SU_PASSWORD trong Config và su-username và su-password trong ConfigLoader, chúng sẽ phục vụ cho việc định nghĩa super-user).Hệ thống chỉ có duy nhất 1 superuser, thông tin đăng nhập của superuser không được lưu trong csdl mà được lưu trong file cấu hình của chúng ta(mặt định tên đăng nhập là admin và password cũng là admin). Superuser sẽ quản lý những người dùng khác thông qua giao diện web.Bắt tay vào làm thôi nào, tạo 1 servlet tên là SuperuserServlet và không kế thừa từ BaseServlet như các servlet khác. Nhiệm vụ của nó chỉ đơn giản là chuyển hướng đến jsp page :|, nội dung chính như sau:
// superuser kiểm tra xem người dùng có đang login trong session hiện tại không
public static boolean logined(HttpServletRequest request) {
String s_logined = (String) request.getSession().getAttribute("logined");
boolean logined = Convert.parseInt(s_logined, 0) != 0;
return logined;
}
// superuser kiểm tra tình trạng login, nếu chưa login thì nó sẽ kiểm tra thông tin đăng nhập và lưu tình trạng login vào session
private void checkLogin(HttpServletRequest request) {
String username = request.getParameter("username");
String password = request.getParameter("password");
if ((username == null || password == null)
|| (!username.equals(Config.SU_USERNAME) || !password.equals(Config.SU_PASSWORD))) {
request.getSession().setAttribute("logined", "0");
} else {
request.getSession().setAttribute("logined", "1");
}
}
// xóa 1 người dùng
private void deleteAccount(HttpServletRequest request) {
int userid = Convert.parseInt(request.getParameter("id"), -1);
SQLMgr.getInstance().deleteAccount(userid);
}
// tạo 1 người dùng mới
private void createAccount(HttpServletRequest request) {
String username = request.getParameter("username");
if (Account.checkUserName(username)) {
String password = request.getParameter("password");
String passwordHash = Security.getPasswordHash(password);
if (passwordHash != null && passwordHash.length() > 0) {
Account account = new Account();
account.setUserName(username);
account.setPasswordHash(passwordHash);
SQLMgr.getInstance().addAccount(account);
}
}
}
// superuser đăng xuất khỏi hệ thống
private void logout(HttpServletRequest request) {
request.getSession().setAttribute("logined", "0");
}
protected void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
if (!logined(request)) {
checkLogin(request);
} else {
String req = request.getParameter("req");
if (req != null) {
switch (req) {
case "delete":
deleteAccount(request);
break;
case "new":
createAccount(request);
break;
case "logout":
logout(request);
break;
}
}
}
RequestDispatcher dispatcher = request.getRequestDispatcher("SuperuserPage.jsp");
dispatcher.forward(request, response);
}
protected void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
doGet(request, response);
}Trang quản lý như sau:
<%
boolean logined = SuperuserServlet.logined(request);
%>
</head>
<frameset rows="80px, *" frameborder="no">
<frame src="Header.jsp" scrolling="no"/>
<%
if (!logined) {
%>
<frame src="Login.jsp"/>
<%
} else {
%>
<frame src="Manager.jsp" name="content" />
<%
}
%>
</frameset>Nếu người dùng chưa login thì nó sẽ tự động chuyển sang trang login ngược lại nó sẽ chuyển sang trang quản lý người dùng.Nội dung trang login khá đơn giản vì thế các bạn có thể xem thêm ở project(link cuối bài). Nội dung của trang quản lý như sau:
<%
boolean logined = SuperuserServlet.logined(request);
%>
</head>
<body>
<%
if (!logined) {
%>
<center>
<h3>You must login to manage users!</h3>
<a href="Login.jsp">Login...</a>
</center>
<%
} else {
List<Account> accounts = SQLMgr.getInstance().getAllAccounts();
if (accounts != null) {
%>
<center>
<a href="NewAccount.jsp">New...</a>
<table style="width: 95%" border="1">
<%
for (int i = 0; i < accounts.size(); i++) {
Account account = accounts.get(i);
%>
<tr>
<td align="left"><%=(i + 1) + ". " + account.getUserName()%></td>
<td align="right"><a
href="SuperuserServlet?req=delete&id=<%=account.getId()%>"
onclick="return confirm('Delete <%=account.getUserName()%>, sure?')"
target="_top">Delete...</a></td>
</tr>
<%
}
%>
</table>
</center>
<%
} else {
%>
<center>
<h3>Something wrong in database!</h3>
</center>
<%
}
}
%>
</body><script type="text/javascript">
function isNumber(code) {
return (code >= 48) && (code <= 57);
}
function isLetter(code) {
return ((code >= 65) && (code <= 90))
|| ((code >= 97) && (code <= 122));
}
function checkSingup() {
var username = document.getElementById("username").value.trim();
var password = document.getElementById("password").value.trim();
var confirm = document.getElementById("confirm").value.trim();
if (username.length < 3) {
alert("User name must be at least 3 characters!");
return false;
}
if (username.indexOf(' ') > -1) {
alert("User name can not be any spaces!");
return false;
}
for (i = 0; i < username.length; i++) {
var code = username.charCodeAt(i);
if (!isNumber(code) && !isLetter(code)) {
if (code != 45 && code != 95) {
alert("User name only numbers, letters, - or _");
return false;
}
}
}
if (password.length < 6) {
alert("Password must be at least 6 characters!");
return false;
}
if (password.localeCompare(confirm) != 0) {
alert("confirm the password again!");
return false;
}
return true;
}
function eventFire(el, etype) {
if (el.fireEvent) {
el.fireEvent('on' + etype);
} else {
var evObj = document.createEvent('Events');
evObj.initEvent(etype, true, false);
el.dispatchEvent(evObj);
}
}
function goback() {
eventFire(document.getElementById('hiddenLink'), 'click');
}
</script>
</head>
<body>
<center>
<h3>Create new account, fill some information below:</h3>
<form action="SuperuserServlet" method="post"
onsubmit="return checkSingup();" target="_top">
<input type="hidden" name="req" value="new"> <a
id="hiddenLink" href="Manager.jsp"></a>
<table>
<tr>
<td>User name:</td>
<td><input id="username" type="text" name="username" /></td>
</tr>
<tr>
<td>Password:</td>
<td><input id="password" type="password" name="password" /></td>
</tr>
<tr>
<td>Confirm:</td>
<td><input id="confirm" type="password" name="confirm" /></td>
</tr>
<tr>
<td />
<td align="right"><input type="button" value="Cancel"
onclick="goback();"> <input type="submit" value="Create">
</td>
</tr>
</table>
</form>
</center>
</body>Trang này yêu cầu người dùng(superuser) nhập tên người dùng và mật khẩu để tạo ra người dùng(normal) mới trong csdl. Trước khi yêu cầu được gửi tới server để thực hiện thì thông tin phải được kiểm tra bằng javascript trước(kiểm tra tên đăng nhập có hợp lệ không, kiểm tra độ dài mật khẩu…)Để tự động chuyển hướng đến trang đăng nhập của superuser khi người dùng chỉ nhập đường dẩn đến webservice(vd như localhost:8080/MyWS) thì ta cần chỉnh sửa lại nội dùng của web.xml như sau:
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://xmlns.jcp.org/xml/ns/javaee" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd" id="WebApp_ID" version="3.1">
<display-name>MyWS</display-name>
<welcome-file-list>
<welcome-file>SuperuserServlet</welcome-file>
</welcome-file-list>
</web-app>Chốt
Qua phân 2 này chúng ta đã hoàn tất được phần chủ chốt là web service, phần 3 tiếp theo sẽ là xây dựng ứng dụng android để làm việc với web service này. Các bạn có thể đọc lại phần 1 tại đây.Mọi source code của project này được cập nhật tại github: https://github.com/xuanson33bk/iot-client-server
References
[1]. https://code.google.com/p/sqlite4java[2]. https://docs.oracle.com/javaee/6/api/javax/servlet/ServletContextListener.html
[3]. http://www.tutorialspoint.com/java/java_serialization.htm
[4]. http://stackoverflow.com/questions/25284556/translate-crc8-from-c-to-java
0 nhận xét :
Post a Comment