/*
* IP Messenger Main Class
* 1997/10/3 (C)Copyright T.Kazawa
*/
package ipmsg;
import JP.digitune.util.ResourceProperties;
import JP.digitune.util.StringReplacer;
import java.awt.*;
//import jp.kyasu.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import java.util.*;
import java.text.*;
import java.math.*;
import java.security.*;
import java.security.interfaces.*;
import java.security.spec.*;
import javax.crypto.*;
import javax.crypto.spec.*;
public class IPMsg implements IPMComListener {
/*========== Constant Value ==========*/
public static final long IPMSG_COMMASK = 0x000000ffL;
public static final long IPMSG_OPTMASK = 0xffffff00L;
public static final long IPMSG_NOOPERATION = 0x00000000L;
public static final long IPMSG_BR_ENTRY = 0x00000001L;
public static final long IPMSG_BR_EXIT = 0x00000002L;
public static final long IPMSG_ANSENTRY = 0x00000003L;
public static final long IPMSG_BR_ABSENCE = 0x00000004L;
public static final long IPMSG_BR_ISGETLIST = 0x00000018L;
public static final long IPMSG_OKGETLIST = 0x00000015L;
public static final long IPMSG_GETLIST = 0x00000016L;
public static final long IPMSG_ANSLIST = 0x00000017L;
public static final long IPMSG_SENDMSG = 0x00000020L;
public static final long IPMSG_RECVMSG = 0x00000021L;
public static final long IPMSG_READMSG = 0x00000030L;
public static final long IPMSG_DELMSG = 0x00000031L;
public static final long IPMSG_GETINFO = 0x00000040L;
public static final long IPMSG_SENDINFO = 0x00000041L;
public static final long IPMSG_GETPUBKEY = 0x00000072L;
public static final long IPMSG_ANSPUBKEY = 0x00000073L;
// other opt
public static final long IPMSG_ABSENCEOPT = 0x00000100L;
public static final long IPMSG_SERVEROPT = 0x00000200L;
public static final long IPMSG_DIALUPOPT = 0x00010000L;
public static final long IPMSG_ENCRYPTOPT = 0x00400000L;
public static final long IPMSG_ENCRYPTOPTOLD = 0x00800000L;
// send opt
public static final long IPMSG_SENDCHECKOPT = 0x00000100L;
public static final long IPMSG_SECRETOPT = 0x00000200L;
public static final long IPMSG_BROADCASTOPT = 0x00000400L;
public static final long IPMSG_MULTICASTOPT = 0x00000800L;
public static final long IPMSG_NOPOPUPOPT = 0x00001000L;
public static final long IPMSG_AUTORETOPT = 0x00002000L;
public static final long IPMSG_RETRYOPT = 0x00004000L;
public static final long IPMSG_PASSWORDOPT = 0x00008000L;
public static final long IPMSG_NOLOGOPT = 0x00020000L;
public static final long IPMSG_NEWMUTIOPT = 0x00040000L;
// encrypt opt
public static final long IPMSG_RSA_512 = 0x00000001L;
public static final long IPMSG_RSA_1024 = 0x00000002L;
public static final long IPMSG_RSA_2048 = 0x00000004L;
public static final long IPMSG_RC2_40 = 0x00001000L;
public static final long IPMSG_RC2_128 = 0x00004000L;
public static final long IPMSG_RC2_256 = 0x00008000L;
public static final long IPMSG_BLOWFISH_128 = 0x00020000L;
public static final long IPMSG_BLOWFISH_256 = 0x00040000L;
public static final int MAXBUF = 8192;
/*========== end ==========*/
private static final String P_FILE = "runtime.properties";
private ResourceProperties pref = new ResourceProperties("ipmsg.resources");
private boolean state = false;
private InetAddress localaddr;
private long serial = 0;
private String user, host;
private Hashtable userlist = new Hashtable();
private Hashtable dialupmember = new Hashtable();
private Hashtable ipmlistener = new Hashtable();
private Hashtable recentsend = new Hashtable();
private int port;
private int[] ports;
private DatagramSocket dsock;
private IPMProxy proxy;
private int receivecount = 0;
private class CryptoInfo {
private long cap = 0L;
private PublicKey publickey = null;
public CryptoInfo(long cap, PublicKey publickey) {
this.cap = cap;
this.publickey = publickey;
}
public long getCap() {
return cap;
}
public PublicKey getPublicKey() {
return publickey;
}
}
private boolean hasJCE = true;
private Hashtable publickeys = new Hashtable();
private PublicKey publickey = null;
private PrivateKey privatekey = null;
private long getCryptoCaps() {
return IPMSG_RSA_512 | IPMSG_RSA_1024
| IPMSG_RC2_40 | IPMSG_RC2_128
| IPMSG_BLOWFISH_128;
}
String makeKey(IPMComEvent ipme) {
IPMPack tmppack = ipme.getPack();
String key = ipme.getIPMAddress() + ":"
+ tmppack.getUser() + ":" + tmppack.getHost();
return key;
}
public void receive(IPMComEvent ipme) {
if (!state)
return;
IPMPack tmppack = ipme.getPack();
long opt = tmppack.getCommand() & IPMSG_OPTMASK;
switch ((int) (tmppack.getCommand() & IPMSG_COMMASK)) {
case (int) IPMSG_BR_ENTRY:
String nickname = pref.getProperty("nickName");
IPMSend.send(dsock, makePack(IPMSG_ANSENTRY | getEntryOpt()
, nickname, true), ipme.getIPMAddress());
case (int) IPMSG_ANSENTRY:
if (publickey != null)
IPMSend.send(dsock, makePack(IPMSG_GETPUBKEY
, Long.toString(getCryptoCaps(), 16).toUpperCase(), false)
, ipme.getIPMAddress());
case (int) IPMSG_BR_ABSENCE:
userlist.put(makeKey(ipme), ipme);
if ((opt & IPMSG_DIALUPOPT) != 0
&& dialupmember.get(ipme.getIPMAddress().toString()) == null)
dialupmember.put(ipme.getIPMAddress().toString()
, ipme.getIPMAddress());
IPMEvent ie = new IPMEvent(this, IPMEvent.UPDATELIST_EVENT
, new Date(System.currentTimeMillis()), ipme);
invokeListener(ie);
break;
case (int) IPMSG_BR_EXIT:
userlist.remove(makeKey(ipme));
dialupmember.remove(ipme.getIPMAddress().toString());
publickeys.remove(ipme.getIPMAddress().toString());
ie = new IPMEvent(this, IPMEvent.UPDATELIST_EVENT
, new Date(System.currentTimeMillis()), ipme);
invokeListener(ie);
break;
case (int) IPMSG_SENDMSG:
if ((opt & IPMSG_SENDCHECKOPT) != 0)
IPMSend.send(dsock
, makePack(IPMSG_RECVMSG | IPMSG_AUTORETOPT
, new Long(tmppack.getNo()).toString(), false)
, ipme.getIPMAddress());
if (new Boolean(pref.getProperty("absenceState")).booleanValue()
&& (opt & IPMSG_AUTORETOPT) == 0)
try {
String tmpmsg = pref.getProperty("absenceMsg");
if (!tmpmsg.equals(""))
IPMSend.send(dsock
, makePack(IPMSG_SENDMSG | IPMSG_AUTORETOPT
, tmpmsg, false), ipme.getIPMAddress());
} catch (MissingResourceException ex) {}
if (!userlist.containsKey(makeKey(ipme))) {
nickname = pref.getProperty("nickName");
IPMSend.send(dsock
, makePack(IPMSG_BR_ENTRY | IPMSG_AUTORETOPT
| getEntryOpt(), nickname, true)
, ipme.getIPMAddress());
}
if ((opt & IPMSG_ENCRYPTOPT) != 0)
tmppack.setExtra(decryptMessage(tmppack.getExtra()));
ie = new IPMEvent(this, IPMEvent.RECEIVEMSG_EVENT
, new Date(System.currentTimeMillis()), ipme);
invokeListener(ie);
break;
case (int) IPMSG_RECVMSG:
try {
Long tmpLong = new Long(tmppack.getExtra());
NormalSend ns = (NormalSend) recentsend.get(tmpLong);
if (ns != null) {
ns.receiveReply();
recentsend.remove(tmpLong);
}
} catch (NumberFormatException ex) {}
break;
case (int) IPMSG_READMSG:
ie = new IPMEvent(this, IPMEvent.READMSG_EVENT
, new Date(System.currentTimeMillis()), ipme);
invokeListener(ie);
break;
case (int) IPMSG_DELMSG:
ie = new IPMEvent(this, IPMEvent.DELETEMSG_EVENT
, new Date(System.currentTimeMillis()), ipme);
invokeListener(ie);
break;
case (int) IPMSG_GETPUBKEY:
IPMSend.send(dsock, makePack(IPMSG_ANSPUBKEY
, answerPublicKey(ipme.getPack()), false)
, ipme.getIPMAddress());
break;
case (int) IPMSG_ANSPUBKEY:
receivePublicKey(ipme);
break;
case (int) IPMSG_GETINFO:
IPMSend.send(dsock, makePack(IPMSG_SENDINFO
, pref.getProperty("version") + " ("
+ System.getProperty("java.vendor") + " ver."
+ System.getProperty("java.version") + "/"
+ System.getProperty("os.name") + " "
+ System.getProperty("os.version") + ")", fals
Java写的鸽子源代码 （108个子文件） 
IPMsg.class 25KB MainWindow.class 11KB ConfDlg.class 8KB IPMProxy.class 6KB RecvDlg.class 6KB IPMPack.class 5KB SendDlg.class 5KB MainWindow$RefreshList.class 3KB ConfDlg$5.class 3KB IPMRecv.class 3KB MsgBox.class 3KB SendDlg$2.class 3KB IPMProxyEvent.class 3KB RecvDlg$4.class 2KB IPMsg$Child.class 2KB NormalSend.class 2KB RecvDlg$5.class 2KB RecvDlg$2.class 2KB Cp932.class 2KB IPMAddress.class 2KB RetryDlg.class 2KB BroadcastSend.class 2KB YesNoBox.class 2KB MessageDigester.class 2KB IPMEvent.class 1KB IPMProxy$Listen.class 1KB StringReplacer.class 1KB ConfDlg$4.class 1KB ResourceProperties.class 1KB IPMsg$1.class 1KB RetryDlg$1.class 1KB IPMSend.class 1KB IPMProxy$KeepAlive.class 1KB SortVector.class 1KB ByteBuffer.class 1KB IPMProxy$Accept.class 1KB MainWindow$13.class 995B ConfDlg$2.class 988B ConfDlg$3.class 966B IPMByteBuffer.class 941B IPMComEvent.class 902B ConfDlg$1.class 876B MainWindow$11.class 823B MainWindow$12.class 795B SendDlg$3.class 788B IPMsg$CryptoInfo.class 775B YesNoBox$2.class 750B YesNoBox$1.class 750B MainWindow$2.class 728B MsgBox$1.class 672B MainWindow$9.class 656B MainWindow$8.class 656B MainWindow$7.class 656B MsgBox$2.class 645B MainWindow$4.class 622B MainWindow$10.class 621B MainWindow$6.class 619B MainWindow$3.class 619B MainWindow$5.class 619B RetryDlg$2.class 604B RecvDlg$3.class 601B SendDlg$4.class 601B ConfDlg$6.class 598B MainWindow$1.class 585B RecvDlg$1.class 574B SendDlg$1.class 574B ConfDlg$7.class 571B Main.class 462B IPMComListener.class 189B IPMListener.class 185B .classpath 226B Thumbs.db 4KB resources_ja.properties.euc 1KB
ipmsg.gif 228B IPMsg.java 27KB MainWindow.java 12KB ConfDlg.java 12KB IPMProxy.java 7KB RecvDlg.java 7KB SendDlg.java 6KB IPMPack.java 5KB Cp932.java 2KB IPMRecv.java 2KB IPMProxyEvent.java 2KB MsgBox.java 2KB RetryDlg.java 2KB NormalSend.java 2KB BroadcastSend.java 1KB YesNoBox.java 1KB IPMAddress.java 1KB IPMSend.java 1KB IPMEvent.java 986B IPMByteBuffer.java 894B ByteBuffer.java 878B ResourceProperties.java 877B StringReplacer.java 788B MessageDigester.java 779B IPMComEvent.java 666B SortVector.java 651B IPMComListener.java 282B共 108 条
- 1
- 2
评论0