A SessionManager' is used to manage all the sessions. The SessionManager’ keeps a list of sessions. When it receives data, it will first check which session the data belongs to. Then the data is given to the corresponding session. If it does not belong to any session in the list, a new session will be created and added to the session list.
The basic code looks like this:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 |
import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketException; import java.util.ArrayList; import java.util.logging.Level; import java.util.logging.Logger; /** * * @author Daoyuan */ public class SessionManager extends Thread { String user; String host; int port; String voiceFile; String defaultVoice; boolean listening = true; public static ArrayList sessionList; DatagramSocket serverSocket = null; public SessionManager(String user, String host, int port, String voiceFile, String defaultVoice) { this.user = user; this.host = host; this.port = port; this.voiceFile = voiceFile; this.defaultVoice = defaultVoice; sessionList = new ArrayList(); try { serverSocket = new DatagramSocket(port); } catch (SocketException ex) { Logger.getLogger(SessionManager.class.getName()).log(Level.SEVERE, null, ex); System.out.println("Unable to listen on port " + port); } } @Override public void run() { byte[] receiveData = newbyte[2048]; new Thread() { @Override public void run() { while (true) { try { Thread.sleep(5); } catch (InterruptedException ex) { Logger.getLogger(SessionManager.class.getName()).log(Level.SEVERE, null, ex); } if (sessionList.size() != 0) { for (int i= 0; i < sessionList.size(); i++) { if (sessionList.get(i).status.equals("destroyed")) { sessionList.remove(i); } } } } } }.start(); while (listening) { DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length); try { serverSocket.receive(receivePacket); } catch (IOException ex) { Logger.getLogger(SessionManager.class.getName()).log(Level.SEVERE, null, ex); } if (isNewSession(receivePacket)) { System.out.println("New session created!"); } } serverSocket.close(); } public void stopListening() { listening = false; } private boolean isNewSession(DatagramPacket receivePacket) { InetAddress IPAddress = receivePacket.getAddress(); int remotePort = receivePacket.getPort(); String sessionName = IPAddress + ":" + remotePort; if (sessionList.size() == 0) { Session s = new Session(this.serverSocket, IPAddress, remotePort, voiceFile, defaultVoice, user); s.setName(sessionName); s.requests.add(receivePacket); sessionList.add(s); s.start(); return true; } else { for (int i = 0; i < sessionList.size(); i++) { if (sessionList.get(i).getName().equals(sessionName)) { sessionList.get(i).requests.add(receivePacket); return false; } } Session s = newSession(this.serverSocket, IPAddress, remotePort, voiceFile, defaultVoice, user); s.setName(sessionName); s.requests.add(receivePacket); sessionList.add(s); s.start(); return true; } } } |
Comments