SmartCanServer
Server for smart can
网联车数据采集服务器
asn.1 协议
配置
server.host = localhost
# 服务端口
server.port = 1080
# 日志表名称
sys.log.tablename = SmartCanServerLog
# sql数据库配置
db.sql.driver = com.mysql.jdbc.Driver
db.sql.url = jdbc:mysql://localhost:3306/sso_iv
db.sql.username = root
db.sql.pwd = baby..520587
# 数据库心跳间隔 毫秒
db.sql.tickInterval = 5000
# 采集频率
sys.can.collectFrequency = 1000
# 发送频率
sys.can.sendFrequency = 1000
# 插件地址
plugin.path = plugin插件开发
杨兴锋
2018-7-17
V1.0
1. 为什么要插件化开发:
1. 将系统核心与业务代码解耦，降低开发，维护成本。
2. 插件可以做什么:
1. 比如做异常处理：告警推送，异常记录等等...
2. 比如做实时数据分析：故障预测，流计算等等...
3. 脚手架工程
参考该目录内 testPlugin 项目
4. 插件开发示例
由于现在插件是同步调用，如果有高延时操作请自行做异步处理
插件包名规范
包名：com.iot.nero.smartcan.plugin.impl
插件类名规范
收到消息扩展点 类名：MessageReceivedListener (收到消息)
示例：
public class MessageReceivedListener implements OnMessageReceivedListener {
@Override
public void OnMessageReceived(Protocol protocol) {
System.out.println("this from plugin2 message received");
}
}异常扩展点 类名：SmartFaultListener (异常)
示例：
public class SmartFaultListener implements OnSmartFaultListener {
@Override
public void onFault(SmartFaultRequestMessage smartFaultRequestMessage) {
System.out.println("this from plugin2 smart fault");
}
}解码扩展点 类名：MessageDecodeListener (解码)
示例：
public class MessageDecodeListener implements OnMessageDecodeListener {
@Override
public void onLogin(LoginRequestMessage loginRequestMessage, SocketChannel socketChannel) throws IOException {
}
@Override
public void onLogout(LogoutRequestMessage logoutRequestMessage, SocketChannel socketChannel) throws IOException {
}
@Override
public void onHeartBeat(HeartbeatMessage heartbeatMessage, SocketChannel socketChannel) throws IOException {
}
@Override
public void onSmartCan(SmartCanRequestBody smartCanRequestBody, SocketChannel socketChannel) throws IOException {
}
@Override
public void onSmartRecogrize(SmartRecognizeRequestMessage smartRecognizeRequestMessage, SocketChannel socketChannel) throws IOException {
}
@Override
public void onSmartStrategy(SmartStrategyRequestMessage smartStrategyRequestMessage, SocketChannel socketChannel) throws IOException {
}
@Override
public void onSmartControl(SmartControlRequestMessage smartControlRequestMessage, SocketChannel socketChannel) throws IOException {
}
@Override
public void onSmartControlFeed(SmartCtrlFeedBackRequestMessage smartCtrlFeedBackRequestMessage, SocketChannel socketChannel) throws IOException {
}
@Override
public void onSmartFault(SmartFaultRequestMessage smartFaultRequestMessage, SocketChannel socketChannel) throws IOException, InstantiationException, IllegalAccessException, NoSuchMethodException, InvocationTargetException {
}
@Override
public void onSmartFormATeam(SmartFromATeamRequestMessage smartFromATeamRequestMessage, SocketChannel socketChannel) throws IOException {
}
@Override
public void onSmartFTeam(SmartFTeamSuccessRequestMessage smartFTeamSuccessRequestMessage, SocketChannel socketChannel) throws IOException {
}
@Override
public void onSmartDissolveTeam(SmartDissolveRequestMessage smartDissolveRequestMessage, SocketChannel socketChannel) throws IOException {
}
@Override
public void onSmartTeam(SmartTeamRequestMessage smartTeamRequestMessage, SocketChannel socketChannel) throws IOException {
}
@Override
public void onSmartPlatonning(SmartPlatonningRequestMessage smartPlatonningRequestMessage, SocketChannel socketChannel) throws IOException {
}
}