diff options
author | Anton Tananaev <anton.tananaev@gmail.com> | 2012-04-27 19:18:28 +0000 |
---|---|---|
committer | Anton Tananaev <anton.tananaev@gmail.com> | 2012-04-27 19:18:28 +0000 |
commit | 89654e64cfa18e19741ea97fe685ccfa2f40788c (patch) | |
tree | 5783e91ece939b047a87977617339d154bd0517b /src/org/traccar/Server.java | |
parent | e9527c7a8a99e09f47e2169676dee85a7834d670 (diff) | |
download | traccar-server-89654e64cfa18e19741ea97fe685ccfa2f40788c.tar.gz traccar-server-89654e64cfa18e19741ea97fe685ccfa2f40788c.tar.bz2 traccar-server-89654e64cfa18e19741ea97fe685ccfa2f40788c.zip |
Diffstat (limited to 'src/org/traccar/Server.java')
-rw-r--r-- | src/org/traccar/Server.java | 125 |
1 files changed, 20 insertions, 105 deletions
diff --git a/src/org/traccar/Server.java b/src/org/traccar/Server.java index 0242a391b..a0506f0cb 100644 --- a/src/org/traccar/Server.java +++ b/src/org/traccar/Server.java @@ -17,29 +17,27 @@ package org.traccar; import java.io.FileInputStream; import java.io.IOException; -import java.sql.ResultSet; import java.sql.SQLException; import java.text.DateFormat; import java.text.SimpleDateFormat; -import java.util.*; -import java.util.logging.Formatter; +import java.util.Date; +import java.util.LinkedList; +import java.util.List; +import java.util.Properties; import java.util.logging.*; import org.jboss.netty.buffer.ChannelBuffers; import org.jboss.netty.channel.ChannelPipeline; import org.jboss.netty.handler.codec.frame.DelimiterBasedFrameDecoder; import org.jboss.netty.handler.codec.string.StringDecoder; import org.jboss.netty.handler.codec.string.StringEncoder; -import org.traccar.helper.AdvancedConnection; -import org.traccar.helper.NamedParameterStatement; import org.traccar.model.DataManager; -import org.traccar.model.Device; -import org.traccar.model.Position; +import org.traccar.model.DatabaseDataManager; import org.traccar.protocol.*; /** * Server */ -public class Server implements DataManager { +public class Server { /** * Server list @@ -57,8 +55,10 @@ public class Server implements DataManager { return loggerEnabled; } + private DataManager dataManager; + /** - * Init + * Initialize */ public void init(String[] arguments) throws IOException, ClassNotFoundException, SQLException { @@ -69,7 +69,8 @@ public class Server implements DataManager { properties.loadFromXML(new FileInputStream(arguments[0])); } - initDatabase(properties); + dataManager = new DatabaseDataManager(properties); + initLogger(properties); initXexunServer(properties); @@ -108,93 +109,7 @@ public class Server implements DataManager { } /** - * Database statements - */ - private NamedParameterStatement selectDevice; - private NamedParameterStatement insertPosition; - - /** - * Init database - */ - private void initDatabase(Properties properties) - throws ClassNotFoundException, SQLException { - - // Load driver - String driver = properties.getProperty("database.driver"); - if (driver != null) { - Class.forName(driver); - } - - // Connect database - String url = properties.getProperty("database.url"); - String user = properties.getProperty("database.user"); - String password = properties.getProperty("database.password"); - AdvancedConnection connection = new AdvancedConnection(url, user, password); - - String query = properties.getProperty("database.selectDevice"); - selectDevice = new NamedParameterStatement(connection, query); - - query = properties.getProperty("database.insertPosition"); - insertPosition = new NamedParameterStatement(connection, query); - } - - /** - * Devices - */ - private Map devices; - private Calendar devicesLastUpdate; - private Long devicesListRefreshDelay = new Long(5 * 60 * 1000); - - public synchronized List getDevices() throws SQLException { - - List deviceList = new LinkedList(); - - selectDevice.prepare(); - ResultSet result = selectDevice.executeQuery(); - while (result.next()) { - Device device = new Device(); - device.setId(result.getLong("id")); - device.setImei(result.getString("imei")); - deviceList.add(device); - } - - return deviceList; - } - - public Device getDeviceByImei(String imei) throws SQLException { - - if ((devices == null) || (Calendar.getInstance().getTimeInMillis() - devicesLastUpdate.getTimeInMillis() > devicesListRefreshDelay)) { - devices = new HashMap(); - List deviceList = getDevices(); - for (Object device: deviceList) { - devices.put(((Device) device).getImei(), device); - } - devicesLastUpdate = Calendar.getInstance(); - } - - return (Device) devices.get(imei); - } - - public synchronized void setPosition(Position position) throws SQLException { - - insertPosition.prepare(); - - insertPosition.setLong("device_id", position.getDeviceId()); - insertPosition.setTimestamp("time", position.getTime()); - insertPosition.setBoolean("valid", position.getValid()); - insertPosition.setDouble("altitude", position.getAltitude()); - insertPosition.setDouble("latitude", position.getLatitude()); - insertPosition.setDouble("longitude", position.getLongitude()); - insertPosition.setDouble("speed", position.getSpeed()); - insertPosition.setDouble("course", position.getCourse()); - insertPosition.setDouble("power", position.getPower()); - insertPosition.setString("extended_info", position.getExtendedInfo()); - - insertPosition.executeUpdate(); - } - - /** - * Init logger + * Initialize logger */ public void initLogger(Properties properties) throws IOException { @@ -265,7 +180,7 @@ public class Server implements DataManager { TrackerServer server = new TrackerServer(getProtocolPort(properties, protocol)); final Integer resetDelay = getProtocolResetDelay(properties, protocol); - server.setPipelineFactory(new GenericPipelineFactory(server, this, isLoggerEnabled()) { + server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled()) { protected void addSpecificHandlers(ChannelPipeline pipeline) { pipeline.addLast("frameDecoder", new XexunFrameDecoder()); pipeline.addLast("stringDecoder", new StringDecoder()); @@ -288,7 +203,7 @@ public class Server implements DataManager { TrackerServer server = new TrackerServer(getProtocolPort(properties, protocol)); final Integer resetDelay = getProtocolResetDelay(properties, protocol); - server.setPipelineFactory(new GenericPipelineFactory(server, this, isLoggerEnabled()) { + server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled()) { protected void addSpecificHandlers(ChannelPipeline pipeline) { byte delimiter[] = { (byte) ';' }; pipeline.addLast("frameDecoder", @@ -314,7 +229,7 @@ public class Server implements DataManager { TrackerServer server = new TrackerServer(getProtocolPort(properties, protocol)); final Integer resetDelay = getProtocolResetDelay(properties, protocol); - server.setPipelineFactory(new GenericPipelineFactory(server, this, isLoggerEnabled()) { + server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled()) { protected void addSpecificHandlers(ChannelPipeline pipeline) { byte delimiter[] = { (byte) ')' }; pipeline.addLast("frameDecoder", @@ -340,7 +255,7 @@ public class Server implements DataManager { TrackerServer server = new TrackerServer(getProtocolPort(properties, protocol)); final Integer resetDelay = getProtocolResetDelay(properties, protocol); - server.setPipelineFactory(new GenericPipelineFactory(server, this, isLoggerEnabled()) { + server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled()) { protected void addSpecificHandlers(ChannelPipeline pipeline) { byte delimiter[] = { (byte) 0x0 }; pipeline.addLast("frameDecoder", @@ -366,7 +281,7 @@ public class Server implements DataManager { TrackerServer server = new TrackerServer(getProtocolPort(properties, protocol)); final Integer resetDelay = getProtocolResetDelay(properties, protocol); - server.setPipelineFactory(new GenericPipelineFactory(server, this, isLoggerEnabled()) { + server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled()) { protected void addSpecificHandlers(ChannelPipeline pipeline) { byte delimiter[] = { (byte) '$' }; pipeline.addLast("frameDecoder", @@ -392,7 +307,7 @@ public class Server implements DataManager { TrackerServer server = new TrackerServer(getProtocolPort(properties, protocol)); final Integer resetDelay = getProtocolResetDelay(properties, protocol); - server.setPipelineFactory(new GenericPipelineFactory(server, this, isLoggerEnabled()) { + server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled()) { protected void addSpecificHandlers(ChannelPipeline pipeline) { byte delimiter[] = { (byte) '\r', (byte) '\n' }; pipeline.addLast("frameDecoder", @@ -418,7 +333,7 @@ public class Server implements DataManager { TrackerServer server = new TrackerServer(getProtocolPort(properties, protocol)); final Integer resetDelay = getProtocolResetDelay(properties, protocol); - server.setPipelineFactory(new GenericPipelineFactory(server, this, isLoggerEnabled()) { + server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled()) { protected void addSpecificHandlers(ChannelPipeline pipeline) { byte delimiter[] = { (byte) '\n' }; // tracker bug \n\r pipeline.addLast("frameDecoder", @@ -443,7 +358,7 @@ public class Server implements DataManager { TrackerServer server = new TrackerServer(getProtocolPort(properties, protocol)); final Integer resetDelay = getProtocolResetDelay(properties, protocol); - server.setPipelineFactory(new GenericPipelineFactory(server, this, isLoggerEnabled()) { + server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled()) { protected void addSpecificHandlers(ChannelPipeline pipeline) { byte delimiter[] = { (byte) '\r', (byte) '\n' }; pipeline.addLast("frameDecoder", |