两个系统之间的通讯问题

业务: 服务器端需要收集每个客户端的月报信息
数据库表: 每个客户端都有t_report月报表,服务器端有一个t_server_report表和一个收集任务表t_server_task
实现:
1 在服务器端人为生成收集任务(t_server_task表中加一条记录)
2 服务器端有个定时(每隔几分钟)运行的程序(在servlet 里执行)扫描收集任务表(t_server_task)查看是否有新的任务.


3 如果有新任务就通知指定的客户端收集月报表信息
4 客户端程序开始运行收集月报信息,然后发送给服务器端(每个客户端的数据量在8000条左右,10个列都是很简单的数据类型)
5 服务器端接收客户端的返回月报信息后插入到服务器端的t_server_report表中,然后进行分析.

注意:服务器端程序不能访问客户端的数据库,客户端的程序也不能访问服务器端的数据库

目前 3 4 5 步不知道怎么实现比较好
希望听听大家的意见

评论

20 楼 jianfeng008cn 2006-11-07  

pdw2009 写道

用一个中间数据表吧，最简单！！！！！不需要做啥修改

得有地方建啊 不是说了 不能互相访问数据库的吗

19 楼 pdw2009 2006-11-06  

用一个中间数据表吧，最简单！！！！！不需要做啥修改

18 楼 hasi 2006-11-01  

通过http传送的类(序列化的类),除了属性和get,set方法,不能包含别的方法,
包含别的方法就出错,这个问题怎么解释?

17 楼 myaniu 2006-10-30  

可以看看ICE
www.zeroc.com
不过，他使用的是双协议，这个可能得考虑。

16 楼 yuanfu 2006-10-29  

1、对于问题3，比较简单，URL就可以搞定；
2、传递大数据量，用http传递序列化java对象，没有问题；当然你的客户端和服务器端都要是java实现；
3、计划任务可以使用Quartz来完成。

15 楼 hasi 2006-10-29  

目前直接用http传递序列化的java对象,效果还可以
下面是我的实现过程
服务器端程序主要代码
TaskListenerServlet.java

public void init() throws ServletException {
	TimerTask myTask = new MyTimerTask();
	myTimer = new Timer();
	long startMin=60;
	long intervalMin=60;
	myTimer.schedule(myTask, startMin*1000, intervalMin*1000);
}

MyTimerTask类里的run()方法主要代码

try {
	// 设置网络输出流,idcServletAddress为客户端的servlet地址
	URL url = new URL(idcServletAddress);
	URLConnection uc = url.openConnection();
	uc.setDoOutput(true);
	uc.setDoInput(true);
	uc.setUseCaches(false);
	uc.setRequestProperty("Content-type", "application/octet-stream");
	ObjectOutputStream requestout = new ObjectOutputStream(uc.getOutputStream());
	//发送给客户端的servlet
	IDCInfoBean idcbean = new IDCInfoBean();
	idcbean.setIdc(idc);
	requestout.writeObject(idcbean);
	requestout.flush();
	requestout.close();
	//获取返回的二进制对象流
	ObjectInputStream responsein = new ObjectInputStream(uc.getInputStream());
	//还原
	TransProgramList tpl=  (TransProgramList) responsein.readObject();
	//把数据保存到服务器端数据库里
	CollectTaskService.executeTask(idc , tpl);
	responsein.close();
}catch (Exception e) {
      throw e;
}

 

客户端servlet程序主要代码

public void service(ServletRequest request, ServletResponse response) throws
    ServletException, IOException {
        //封装用于返回的对象输出流         
	ObjectOutputStream out = new ObjectOutputStream(response.getOutputStream());     
	//封装用于接收的对象输入流     
	ObjectInputStream in = new ObjectInputStream(request.getInputStream());     
	IDCInfoBean idcBean=new IDCInfoBean();     
	//按指定类的格式读取对象输入流中的内容     
	try {        
		idcBean=(IDCInfoBean)in.readObject();         
	}catch (Exception e ){
		System.out.println(e.toString());
		//
	}
	String idc = idcBean.getIdc();
	//得到客户端所有节目信息
	List programList =CollectService.collectProgram(idc) ;
	List multiList =CollectService.collectMultiProgram(idc) ;
	//把结果封装到序列化对象里
	TransProgramList tpl = new TransProgramList();
	tpl.setProgramList(programList);
	tpl.setMultiList(multiList);
	//发送对象
	out.writeObject(tpl);    
}    

14 楼 Jamsa 2006-10-29  

这样的业务是否该使用消息驱动POJO

13 楼 lordhong 2006-10-28  

直接用Hessian啊，几个POJO直接在HTTP上传过去，很简单

12 楼 bluemeteor 2006-10-27  

数据放到memcache里面  通过webservice提供访问接口

11 楼 ddandyy 2006-10-27  

我们这个项目有类似的应用
我们这个是中间用一个FTP中转  一边写文件  一边读文件

这个是客户定下的

10 楼 hasi 2006-10-27  

Ivan Li 写道

8000多条记录呢，http中get方法url的大小是有限制的，好像是128k，我觉得字符串的不可行

对象序列化后用http传送

9 楼 greenq 2006-10-27  

想都不用想，       socket啊。
还webservice，      好大的的一把牛刀

8 楼 iceboundrock 2006-10-27  

用cindy框架可以减少一些socket的复杂度，具体可以参考
http://cindy.sf.net

7 楼 抛出异常的爱 2006-10-27  

Ivan Li 写道

8000多条记录呢，http中get方法url的大小是有限制的，好像是128k，我觉得字符串的不可行

当时的数据也不少
只是懒的作模块了
每条数据发一个url中间用个定时器隔开
(每条数据给10秒时间)
(呵呵.....谁让他们只给三天时间呢?)

6 楼 IvanLi 2006-10-27  

8000多条记录呢，http中get方法url的大小是有限制的，好像是128k，我觉得字符串的不可行

5 楼 抛出异常的爱 2006-10-27  

url传.....
作过一次维护
就是组成一个字符串
给另一个系统发url
由另一系统处理

4 楼 rtdb 2006-10-27  

Socket太底层了，比较麻烦。用WEB Service之类的好了。

3 楼 hasi 2006-10-27  

Socket 以前没有接触过，刚查了一些资料，应该很适合的

2 楼 sorphi 2006-10-27  

sock编程就可以了吧？

1 楼 hasi 2006-10-27  

数据通过http传递有没有问题？
RMI可不可以？