Java即时通讯源代码

package ict.ff.ipmsg; import java.io.*; import java.net.*; import java.nio.ByteBuffer; import java.nio.channels.DatagramChannel; import java.nio.charset.Charset; import java.util.*; public class IpmsgChannel { private class ServerSockThread extends Thread { public void run() { try { while(!isclosed) { Socket sock = server.accept(); byte buffer[] = new byte[300]; InputStream input = sock.getInputStream(); int length = input.read(buffer); FileData file = getFileData(buffer, length); if(file == null) { sock.close(); } else { int mode = IPMSG.GET_MODE(file.attr); AutoPipe pipe = null; if(mode == 1) pipe = new AutoPipe(new FileInputStream(file.name), sock.getOutputStream()); else if(mode == 2) pipe = new AutoPipe(new DirectoryInputStream(file.name), sock.getOutputStream()); if(pipe != null) pipe.start(); else sock.close(); } } } catch(IOException ioexception) { // break MISSING_BLOCK_LABEL_249; } // break MISSING_BLOCK_LABEL_208; // Exception exception; // exception; if(server != null) try { server.close(); server = null; } catch(IOException e) { e.printStackTrace(); } // throw exception; if(server != null) try { server.close(); server = null; } catch(IOException e) { e.printStackTrace(); } // break MISSING_BLOCK_LABEL_287; if(server != null) try { server.close(); server = null; } catch(IOException e) { e.printStackTrace(); } } private FileData getFileData(byte buffer[], int length) { String parts[]; int packetID; String msg = getMessage(buffer, length); parts = msg.split(":"); packetID = Integer.parseInt(parts[0], 16); int fileID = Integer.parseInt(parts[1], 16); ArrayList arraylist = waitingList; // JVM INSTR monitorenter ; Iterator iterator = waitingList.iterator(); while(iterator.hasNext()) { FileData file = (FileData)iterator.next(); if(file.packetID == packetID && file.fileID == fileID) return file; } // arraylist; // JVM INSTR monitorexit ; // goto _L1 // arraylist; // JVM INSTR monitorexit ; // throw ; //_L1: return null; } final IpmsgChannel this$0; private ServerSockThread() { this$0 = IpmsgChannel.this; // super(); } ServerSockThread(ServerSockThread serversockthread) { this(); } } public IpmsgChannel() throws IOException { this(null, null); } public IpmsgChannel(String nickname, String groupname) throws IOException { charset = null; this.name = null; this.hostname = null; this.nickname = null; this.groupname = null; absenceInfo = null; members = null; listeners = null; isclosed = false; packetNo = 0; channel = null; sendBuffer = null; receiveBuffer = null; serverThread = null; server = null; waitingList = null; members = new ArrayList(); listeners = new Observable[4]; for (int i = 0; i < 4; i++) listeners[i] = new Observable() { public void notifyObservers(Object arg) { super.setChanged(); super.notifyObservers(arg); } final IpmsgChannel this$0; { this$0 = IpmsgChannel.this; // super(); } }; charset = "GB2312"; absenceInfo = "Not absence mode"; String name = System.getProperty("user.name"); String hostname = InetAddress.getLocalHost().getHostName(); setName(name); setHostName(hostname); setNickName(nickname); setGroupName(groupname); channel = DatagramChannel.open(); channel.configureBlocking(false); DatagramSocket socket = channel.socket(); socket.setReuseAddress(true); socket.setBroadcast(true); socket.bind(new InetSocketAddress(2425)); sendBuffer = ByteBuffer.allocateDirect(8192); receiveBuffer = ByteBuffer.allocateDirect(8192); server = new ServerSocket(2425); serverThread = new ServerSockThread(null); serverThread.start(); waitingList = new ArrayList(); } public String getNickName() { return nickname; } public String getName() { return name; } public String getHostName() { return hostname; } public ArrayList getMembers() { return members; } public boolean setNickName(String nickname) { if (nickname == null || nickname.indexOf(":") != -1) { this.nickname = ""; return false; } else { this.nickname = nickname; return true; } } public boolean setGroupName(String groupname) { if (groupname == null || groupname.indexOf(":") != -1) { this.groupname = ""; return false; } else { this.groupname = groupname; return true; } } protected boolean setName(String name) { if (name == null || name.indexOf(":") != -1) { this.name = "no name"; return false; } else { this.name = name; return true; } } protected boolean setHostName(String hostname) { if (hostname == null || hostname.indexOf(":") != -1) { this.hostname = "no name"; return false; } else { this.hostname = hostname; return true; } } public boolean setAbsence(String absenceInfo) { if (absenceInfo == null || absenceInfo.indexOf(":") != -1) { this.absenceInfo = "Not absence mode"; return false; } else { this.absenceInfo = absenceInfo; return true; } } public String getCharsetName() { return charset; } public void setCharsetName(String charset) { if (Charset.isSupported(charset)) { this.charset = charset; } else { this.charset = Charset.defaultCharset().name(); System.out.println((new StringBuilder("cannot encode in charset:")) .append(charset).append("switch to default:").append( this.charset).toString()); } } public boolean readAndDispatch() { SocketAddress address = null; receiveBuffer.clear(); try { address = channel.receive(receiveBuffer); } catch (IOException e) { e.printStackTrace(); } if (address == null) { return false; } else { receiveBuffer.flip(); byte data[] = new byte[receiveBuffer.remaining()]; receiveBuffer.get(data); processDatagramPacket(address, data); return true; } } public void close() { isclosed = true; try { if (channel != null) channel.close(); if (server != null) { server.close(); server = null; } } catch (IOException e) { e.printStackTrace(); } } public void addListener(int eventType, Observer listener) { if (eventType >= listeners.length) throw new IllegalArgumentException("unknown event type");