socketreceiver.java

一个用于实现不同数据库数据同步的程序

import java.net.*;
import javax.net.ssl.*;
import java.io.*;
import java.security.*;
import java.io.*;

//数据库Agent的接受器，监听有否从其他Agent发来的更新信息
 
public class socketReceiver extends Thread
{

	private static String databaseName="";private static String txtAddress="";/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

	private int myPort=0;
	private String sslKey="";
	char keyStorePass[]=null;  //证书密码
	char keyPassword[]=null;
	

	public void init()
	{
		sqlOperation so=new sqlOperation();
		myPort=Integer.parseInt(so.StringFromDB("select * from DBINFORMATION where STATE=1","DBRECEIVEPORT"));
		sslKey=so.StringFromDB("select * from DBINFORMATION where STATE=1","SSL");
		String p=so.StringFromDB("select * from DBINFORMATION where STATE=1","PASSWORD");
		keyStorePass=p.toCharArray();
		keyPassword=p.toCharArray();
	}

	public static void main(String[] args)
	{
		socketReceiver sr=new socketReceiver();
		sr.init();
		sr.start();
		
		char answer = '\0';
		while(true)
		{
			try{
				System.out.println("To end program, type Q or q, type any other kye to continue");
				answer = (char)System.in.read(); 
			}catch(Exception e){}

			if(answer=='Q'|| answer=='q')
			{
				System.exit(1);
			}
		}
	}

	public void run()
	{
		String s="";

		try
		{
		KeyStore ks=KeyStore.getInstance("JKS");  //创建JKS密钥库
		ks.load(new FileInputStream(sslKey),keyStorePass);
		KeyManagerFactory kmf=KeyManagerFactory.getInstance("SunX509");
		kmf.init(ks,keyPassword);
		SSLContext sslContext=SSLContext.getInstance("SSLv3");
		sslContext.init(kmf.getKeyManagers(),null,null);
		//根据上面配置的SSL上下文来产生SSLServerSocketFactory,与通常的产生方法不同
		SSLServerSocketFactory factory=sslContext.getServerSocketFactory();
		SSLServerSocket sslsocket=(SSLServerSocket)factory.createServerSocket(myPort);
		
		SSLSocket mySocket=null;
		BufferedReader in;
		PrintWriter out;

			for(;;)
			{
				mySocket=(SSLSocket)sslsocket.accept();
				in=new BufferedReader(new InputStreamReader(mySocket.getInputStream(),"gb2312"));
				out=new PrintWriter(mySocket.getOutputStream(),true);
				s=in.readLine();
System.out.println(s);
				if((!s.equals(null))||(!s.equals(" ")))
				{
					Thread rm=new receiveMesg(s,databaseName,txtAddress);
					rm.start();
				}
				
				try
				{
					sleep(1000);
				}
				catch(InterruptedException e){}
			}

			
		}
		catch(Exception e){}

		
	}
}