• 北京: 千橡集团暨校内网诚聘软件研发工程师
• 搜狐网站诚聘Java、PHP和C++工程师

• 北京: 千橡集团暨校内网诚聘软件研发工程师
• 搜狐网站诚聘Java、PHP和C++工程师

• 搜狐网站诚聘Java、PHP和C++工程师
• 北京: 千橡集团暨校内网诚聘软件研发工程师

• 搜狐网站诚聘Java、PHP和C++工程师
• 北京: 千橡集团暨校内网诚聘软件研发工程师

• 搜狐网站诚聘Java、PHP和C++工程师
• 北京: 千橡集团暨校内网诚聘软件研发工程师

• 搜狐网站诚聘Java、PHP和C++工程师
• 北京: 千橡集团暨校内网诚聘软件研发工程师

• 北京: 千橡集团暨校内网诚聘软件研发工程师
• 搜狐网站诚聘Java、PHP和C++工程师

Ad ad = new Ad();
Delivery d = new ProportionDelivery(ad, proportion);
ad.setDelivery(d);
session.merge(ad); //此处ok
Delivery other = new CountDelivery(ad, maxcount);
ad.setDelivery(other);
session.merge(ad); //此处失败， 因为新旧的Delivery主键会冲突

ad.setDelivery(other);
session.merge(ad);

• 北京: 千橡集团暨校内网诚聘软件研发工程师
• 搜狐网站诚聘Java、PHP和C++工程师

公司的服务器需要实时监控，而且当用户空间已经满了，操作失败，或者出现程序Exception的时候就需要实时提醒，便于网管和程序员调式，这样就把这个实时监控系统分为了两部分，

第一部分：实时系统监控（cpu利用率，cpu温度，总内存大小，已使用内存大小）

第二部分：实时告警

由于无刷新实时性，所以只能使用Ajax，这里没有用到任何ajax框架，因为调用比较简单

大家知道，由于java的先天不足，对底层系统的调用和操作一般用jni来完成，特别是cpu温度，你在window下是打死用命令行是得不到的，但由于我们的服务器系统是linux，所以可以不调用jni完全用java的方式来得到系统信息，这里用到了runtime的exec()函数，通过解析本地命令调用的结果来查询本地信息，

这里要感谢公司同事qinkun推荐ecsun兄的这篇文章http://papa.javaeye.com/blog/220532，

* 取得linux系统下的cpu、内存信息 
* 
* */ 
public final class LinuxSystemTool 
{ 
/** 
* get memory by used info 
* 
* @return int[] result 
* result.length==4;int[0]=MemTotal;int[1]=MemFree;int[2]=SwapTotal;int[3]=SwapFree; 
* @throws IOException 
* @throws InterruptedException 
*/ 
public static int[] getMemInfo() throws IOException, InterruptedException 
{ 
File file = new File("/proc/meminfo"); 
BufferedReader br = new BufferedReader(new InputStreamReader( 
new FileInputStream(file))); 
int[] result = new int[4]; 
String str = null; 
StringTokenizer token = null; 
while((str = br.readLine()) != null) 
{ 
token = new StringTokenizer(str); 
if(!token.hasMoreTokens()) 
continue; 

str = token.nextToken(); 
if(!token.hasMoreTokens()) 
continue; 

if(str.equalsIgnoreCase("MemTotal:")) 
result[0] = Integer.parseInt(token.nextToken()); 
else if(str.equalsIgnoreCase("MemFree:")) 
result[1] = Integer.parseInt(token.nextToken()); 
else if(str.equalsIgnoreCase("SwapTotal:")) 
result[2] = Integer.parseInt(token.nextToken()); 
else if(str.equalsIgnoreCase("SwapFree:")) 
result[3] = Integer.parseInt(token.nextToken()); 
} 

return result; 
} 

/** 
* get memory by used info 
* 
* @return float efficiency 
* @throws IOException 
* @throws InterruptedException 
*/ 
public static float getCpuInfo() throws IOException, InterruptedException 
{ 
File file = new File("/proc/stat"); 
BufferedReader br = new BufferedReader(new InputStreamReader( 
new FileInputStream(file))); 
StringTokenizer token = new StringTokenizer(br.readLine()); 
token.nextToken(); 
int user1 = Integer.parseInt(token.nextToken()); 
int nice1 = Integer.parseInt(token.nextToken()); 
int sys1 = Integer.parseInt(token.nextToken()); 
int idle1 = Integer.parseInt(token.nextToken()); 

Thread.sleep(1000); 

br = new BufferedReader( 
new InputStreamReader(new FileInputStream(file))); 
token = new StringTokenizer(br.readLine()); 
token.nextToken(); 
int user2 = Integer.parseInt(token.nextToken()); 
int nice2 = Integer.parseInt(token.nextToken()); 
int sys2 = Integer.parseInt(token.nextToken()); 
int idle2 = Integer.parseInt(token.nextToken()); 

return (float)((user2 + sys2 + nice2) - (user1 + sys1 + nice1)) / (float)((user2 + nice2 + sys2 + idle2) - (user1 + nice1 + sys1 + idle1)); 
} 
} 

这里的两个方法，解释一下，

方法1文件"/proc/meminfo"里面包含的就是内存的信息，还包括了swap的信息。例如：

$ cat /proc/meminfo

total: used: free: shared: buffers: cached:
Mem: 1057009664 851668992 205340672 0 67616768 367820800
Swap: 2146787328 164429824 1982357504
MemTotal: 1032236 kB
MemFree: 200528 kB
MemShared: 0 kB
这样可以用截取字符串的方法，来得到linux内存信息.

方法2在文件"/proc/stat"里面就包含了CPU的信息。每一个CPU的每一tick用在什么地方都在这个文件里面记着。后面的数字含义分别是： user、nice、sys、idle、iowait。有些版本的kernel没有iowait这一项。这些数值表示从开机到现在，CPU的每tick用在了哪里。例如：

cpu0 256279030 0 11832528 1637168262

就是cpu0从开机到现在有 256279030 tick用在了user消耗，11832528用在了sys消耗。所以如果想计算单位时间（例如1s）里面CPU的负载，那只需要计算1秒前后数值的差除以每一秒的tick数量就可以了。

ok这样还剩下cpu温度，怎么做呢

发现了一个文件"cat /proc/acpi/thermal_zone/THM/temperature";可以返回本机的linux温度，

大概是这样的：temperature：            68C

但不是每台linux机器都有这个THM你要确定你的linux加载了这个THM才能使用这个文件，这样就用InputStreamReader(new FileInputStream（new File("/proc/acpi/thermal_zone/THM/temperature")）,去读取这个文件，后面的相信大家一定会做了吧，就是把内容读出来,然后分割字符串去得到这个68。ok,系统基本信息全部完成，然后ok现在就只有一件事就是用Ajax去调用这个类来得到 基本信息，然后返回到页面上，Ajax的用法就不赘言了。

下面是系统监控的效果，大概是Ajax每几秒去linux下去取一次系统信息，然后显示在jsp页面上，以下是效果。

到这里第一部分系统监控部分已经完成，现在开始完成实时告警部分，分析需求

1温度和cpu超过额定值需要告警

2用户操作系统失败，用户存储空间不足也需要告警，还有我们公司的业务操作失败告警，如果发生Exception也只能告警，当然要把异常的堆栈的信息保存在数据库里，我就这样设计如果用户在操作中触发了这些错误，则保存在数据库的告警表里，然后实时监控的再取出来这些信息。

3告警是要实时的那么要怎么从告警表里查到当前以后的数据呢，一开始想到用当前时间，在当前时间加上Ajax发送时间间隔，select * from warnlist where date>new Date()+AjaxTime这种形式,后来发现时间是很不正确的，网络延迟，程序处理时间，（cpu信息用了sleep函数），等等你常常会发现有些告警信息被无情的放过，而有的时候有重复数据，这样我想到了用id，每次进入告警系统先查询到最大的告警id,然后保存在session中，然后ajax从数据库里取告警信息的时候都查这个id之后的数据（就是进入监控系统后的最新数据），然后session再保存新的最大id,下次ajax取还是从这个session中取最大id,这样信息就可以当ajax取的时候都保证是最新的，而且没有重复，very good!就这样做了

这样设计了一张告警处理表

CREATE TABLE `warnlist` (
  `Id` bigint(20) NOT NULL auto_increment,
  `warnleave` tinyint(2) NOT NULL default '0',//告警级别：告警的严重程度
  `fromguy` varchar(20) NOT NULL,//属于哪个用户哪个组织的告警
  `warncontent` varchar(100) NOT NULL,//告警内容，比如cpu使用率超过80%
  `aviliablevalue` varchar(12) default NULL,//允许值 比如85%
  `warnvalue` varchar(12) default NULL,//告警值 80
  `warntime` datetime NOT NULL,//告警时间
  `stackinfo` varchar(255) default NULL,//异常的堆栈信息
  `dealwith` tinyint(2) NOT NULL default '0',//处理结果
  `version` int(11) default NULL,//version
  `organizerID` varchar(20) default NULL,//组织id
  `des` varchar(255) default NULL,
  PRIMARY KEY  (`Id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

假设我ajax从系统取信息后，那么要写个逻辑，if(cpuTempature>75C)or if(cpuUserd>80%)则写入数据库，然后再查询大于上一次发送Ajax数据库的最大id的告警信息（这期间如果发生的以下错误一并查出：用户存储空间不足，还有我们公司的业务操作失败告警，Exception等），循环插入一个xml解析类中，大概形式是这样的Ajax返回这个xml,供页面提取信息

<response>
<cpuUsed>67</cpuUsed>
<cpuTemp>76<cpuTemp>
<Memory>1023422</Memory>
<freeMemory>43244</freeMemory>
<wannlist>
<warnid>2</warnid>
<warncontent>系统存储空间不足</warncontent>
<fromguy>kakaluyi</fromguy>
..............
</wanrlist>
<warnlist>
<warnid>3</warnid>
<warncontent>cpu温度过高</warncontent>
<fromguy>系统</fromguy>
<orgid>系统</orgid>
<warnvalue>78</warnvalue>
.............
</warnlist>
........

</response>

系统信息的显示代码，就是关联上面那个图片的：

var cpuUsed=req.responseXML.getElementsByTagName('cpuUsed')[0].firstChild.nodeValue;
var totalMemory=req.responseXML.getElementsByTagName('totalMemory')[0].firstChild.nodeValue;
var freeMemory=req.responseXML.getElementsByTagName('freeMemory')[0].firstChild.nodeValue;
var cpuTemp=req.responseXML.getElementsByTagName('cpuTemp')[0].firstChild.nodeValue;
$('cpuUsed').innerHTML=cpuUsed;
$('totalMemory').innerHTML=totalMemory;
$('freeMemory').innerHTML=freeMemory;
$('cpuTemp').innerHTML=cpuTemp;

//jsp
<tr>
<td class="label" width="20%">
服务器CPU使用率：</td>
<td class="text">
<font color="#FF0000" size="+2"><label id="cpuUsed"></label>
</font> < 告警预定阀值: 80% >
</td>
</tr>
 .........

然后就是页面展现的问题了这里我用了dom节点的增删，一个页面保持50条记录，如果超过50条则删除以前的节点，代码为：

var length=req.responseXML.getElementsByTagName('warnlist').length;
if(length>0)
{
var trlength=document.getElementsByTagName('table')[4].childNodes[0].childNodes.length;

if(trlength+length-1>50)//如果大于50条，则查找告警列表的table，得到
告警信息的子节点，然后删除多余的最早的告警信息
{
var tbody=document.getElementsByTagName('table')[4].childNodes[0];
for(var i=1;i<trlength+length-50;i++)
{
var tr=tbody.childNodes[i];
tr.parentNode.removeChild(tr);

}

然后插入新的告警信息，

for(var i=0;i<length;i++)
{
var onewarnlist=req.responseXML.getElementsByTagName('warnlist')[i].childNodes;
if(onewarnlist[0].firstChild.nodeValue==0)
{
var leave="企业级告警";
}
else {
var leave="运营商级告警";
}
var from=onewarnlist[1].firstChild.nodeValue;
var warncontent=onewarnlist[2].firstChild.nodeValue;
var aviliablevalue=onewarnlist[3].firstChild.nodeValue;
var warnvalue=onewarnlist[4].firstChild.nodeValue;
var warntime=onewarnlist[5].firstChild.nodeValue;
var id=onewarnlist[8].firstChild.nodeValue;
if(onewarnlist[6].firstChild.nodeValue==0)
{
var dealwith="未处理" ;
}
else {
var dealwith="<font color='red'>已处理</font>";
}
var table=document.getElementById('warntable');
var tr=document.createElement('tr');
 if(x%2==1)
{
tr.style.backgroundColor="#BFD3F9"
}
else{
tr.style.backgroundColor="#FBFCEB"
}
x++;
table.appendChild(tr);
var td=document.createElement('td');
td.className ='listText';
td.innerHTML =x;
tr.appendChild(td);
var td1=document.createElement('td');
td1.className ='listText';
td1.innerHTML = leave;
tr.appendChild(td1);
var td2=document.createElement('td');
td2.className ='listText';
td2.innerHTML = from;
tr.appendChild(td2);
var td3=document.createElement('td');
td3.className ='listText';
td3.innerHTML = warncontent;
tr.appendChild(td3);6
var td4=document.createElement('td');
td4.className ='listText';
td4.innerHTML = aviliablevalue;
tr.appendChild(td4);
var td5=document.createElement('td');
td5.className ='listText';
td5.innerHTML = '<font color="#FF0000">'+warnvalue+'</font>';
tr.appendChild(td5);
var td6=document.createElement('td');
td6.className ='listText';
td6.innerHTML = warntime;
tr.appendChild(td6);
var td7=document.createElement('td');
td7.className ='listText';
td7.innerHTML = dealwith;
tr.appendChild(td7);
var td8=document.createElement('td');
td8.className ='listText';
td8.innerHTML = id;
tr.appendChild(td8);
   }

ok，一切大功告成，以下是最终效果

• 北京: 千橡集团暨校内网诚聘软件研发工程师
• 搜狐网站诚聘Java、PHP和C++工程师

//通过SQL反回对应的数据集
//比如:sql select nameSc,age from users
public List getResultDataList(String sql, Connection con) {
		List<Map> dataList = new ArrayList<Map>();
		Map<String, String> map = new HashMap<String, String>();//存放对应字段数据
		PreparedStatement ps = null;
		ResultSet ds = null;
		ResultSetMetaData rsd;
		try {
			ps = con.prepareStatement(sql);
			ds = ps.executeQuery();
			while (ds.next()) {
				map = new HashMap<String, String>();//通过键值对存放一条记录的数据
				rsd = ds.getMetaData();
				for (int i = 1; i <= rsd.getColumnCount(); i++) {
					switch (rsd.getColumnType(i)) {//通过判断数据类型转换数据
					case 12:// varchar(12)
						map.put(rsd.getColumnName(i), ds.getString(i));
						break;
					case 1:// char(1)
						map.put(rsd.getColumnName(i), ds.getString(i));
						break;
					case -7:// bit(-7)
						map.put(rsd.getColumnName(i), Boolean.toString(ds
								.getBoolean(i)));
						break;
					case 4:// int(4)
						map.put(rsd.getColumnName(i), Integer.toString(ds
								.getInt(i)));
						break;
					case 5:// smallint(5)
						map.put(rsd.getColumnName(i), Integer.toString(ds
								.getInt(i)));
						break;	
					case 93:// datetime(93)
						if (ds.getString(i) == null)
							map.put(rsd.getColumnName(i), "");
						else {
							if (ds.getString(i).length() >= 19) {
								map.put(rsd.getColumnName(i), ds.getString(i)
										.substring(0, 19));
							} else {
								map.put(rsd.getColumnName(i), ds.getString(i)
										.substring(0, 10));
							}
						}
						break;
					case 3:// decimal(3)
						map.put(rsd.getColumnName(i), Double.toString(ds
								.getDouble(i)));
						break;
					default:
						map.put(rsd.getColumnName(i), ds.getString(i));
						break;
					}
				}
				dataList.add( map);//存放所有行数据
			}
		} catch (SQLException e) {
			e.printStackTrace();
			throw new RuntimeException(e);
		} finally {
                        connection是通过HibernateDaoSupport获取得到的，似乎能够自动回收（反回到连接池），是否真的不用关闭连接呢？
			/*
			 * try{ if(ds!=null){ds.close();ds=null;}
			 * if(ps!=null){ps.close();ps=null;}
			 * if(con!=null){con.close();con=null;} }catch(SQLException e){}
			 */
		}
		return dataList;
	}

//通过传递SQL,Sql的参数更新数据
//比如 sql insert into users(nameCs,age)valuse(?,?)
//params就是存放?代表的值
public int execUpdateByParams(String sql, Connection con, List params) {
		PreparedStatement ps = null;
		int message = 0;
		try {
			String paramsStr="";
			ps = con.prepareStatement(sql);
			if (params != null) {
				for (int i = 0; i < params.size(); i++) {
					String p = params.get(i)==null?null:"" + params.get(i);//设置对应的参数
					ps.setString(i + 1, p);
				}
			}
			ps.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
			message = -1;
			throw new RuntimeException(e);
		} finally {
			try {
				if (ps != null) {
					ps.close();//怎么在这他有把这个关闭了呢？这会有问题吧？
					ps = null;
				}
				// if(con!=null){con.close();con=null;}
			} catch (SQLException e) {
			}
		}

		return message;
	}

• 搜狐网站诚聘Java、PHP和C++工程师
• 北京: 千橡集团暨校内网诚聘软件研发工程师

• 搜狐网站诚聘Java、PHP和C++工程师
• 北京: 千橡集团暨校内网诚聘软件研发工程师

　　 这个用了很多的时间都搞得成功，参考了不同的书籍，最后都成功了，在这里我把我的心得在这里写写

     首先，下载ActiveMq5.1，大家可以在官方网站下载：当大家下载解压后，就将文件夹的的包ＣＯＰＹ到web project下的lib文件夹里，需要拷贝的以下图的包(j2ee和jre除外)

好了，现在开始写配置文件了。在src文件夹下新建一spring配置文件名为：applicationContext.xml。其代码如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:amq="http://activemq.apache.org/schema/core"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
  http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">

	<bean id="jmsConnectionFactory"
		class="org.springframework.jndi.JndiObjectFactoryBean">
		<property name="jndiName" value="java:comp/env/jms/ConnectionFactory"></property>
	</bean>

	<bean id="jmsQueue"
		class="org.springframework.jndi.JndiObjectFactoryBean">
		<property name="jndiName" value="java:comp/env/jms/Queue"></property>
	</bean>

	<bean id="jmsTemplate"
		class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory" ref="jmsConnectionFactory"></property>
		<property name="defaultDestination" ref="jmsQueue"></property>
	</bean>

	<bean id="sender" class="message.Sender">
		<property name="jmsTemplate" ref="jmsTemplate"></property>
	</bean>

	<bean id="receive" class="message.Receiver"></bean>
	<bean id="listenerContainer"
		class="org.springframework.jms.listener.DefaultMessageListenerContainer">
		<property name="connectionFactory" ref="jmsConnectionFactory"></property>
		<property name="destination" ref="jmsQueue"></property>
		<property name="messageListener" ref="receive"></property>
	</bean>


</beans>

这里中，其中就有一个地方花了我很多时间找资料。这里是用了ActiveMq的方式来配置Spring的配置文件，其中引入了xsd的文件。

<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:amq="http://activemq.apache.org/schema/core"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
               http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
               http://activemq.apache.org/schema/core 
               http://activemq.apache.org/schema/core/activemq-core.xsd">

...................

<beans>

  由于面的配置文件中使用了jndi，所以也得在Tomcat目录下的conf/context.xml配置,需加入

<Resource name="jms/ConnectionFactory" 
  auth="Container"   
  type="org.apache.activemq.ActiveMQConnectionFactory" 
  description="JMS Connection Factory"
  factory="org.apache.activemq.jndi.JNDIReferenceFactory" 
  brokerURL="vm://localhost" 
  brokerName="LocalActiveMQBroker"/>
 
<Resource name="jms/Queue" 
auth="Container" 
type="org.apache.activemq.command.ActiveMQQueue"
description="my Queue"
factory="org.apache.activemq.jndi.JNDIReferenceFactory" 
physicalName="FOO.BAR"/>

 在这里我分别配置了jmsConnectionFactory和jms点对点

  之后，就由消息生产者的代码

package message;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;


public class Sender {

	private JmsTemplate jmsTemplate;

	public void setJmsTemplate(JmsTemplate jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}
	
	public void send(final String text){
		System.out.println("---Send:"+text);
		jmsTemplate.send(new MessageCreator(){

			public Message createMessage(Session arg0) throws JMSException {
				// TODO Auto-generated method stub
				return arg0.createTextMessage(text);
			}
			
		});
	}

}

消息接收者

package message;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

public class Receiver implements MessageListener {

	public void onMessage(Message message) {
		if (message instanceof TextMessage) {
			TextMessage text = (TextMessage) message;

			try {
				System.out.println("Receive:" + text.getText());
			} catch (JMSException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}

		}
	}
}

这里分别帖了最简单的JMS配置，希望对初入门的有用。

• 北京: 千橡集团暨校内网诚聘软件研发工程师
• 搜狐网站诚聘Java、PHP和C++工程师

public interface Dao {
	public abstract List getList(int first,int max) throws Exception;
	public abstract int getTotal()throws Exception;
}

public abstract class AbsDao extends HibernateDaoSupport implements Dao {
	
	/**
	 *@return List 以集合形式返回符合HQL语句中实体 
	 *@param int max 最大记录数
	 *@param int first 第一条记录的位置
	 */
	public List getList(final int first,final int max)throws Exception{
		
		return super.getHibernateTemplate().executeFind(
			new HibernateCallback(){
				public Object doInHibernate(Session session) throws HibernateException,SQLException{
					try{
						return session.createQuery("from "+getTableName()).setFirstResult(first).setMaxResults(max).list();
					}
					catch(Exception e){
						throw new HibernateException(e);
					}
				}
			}
		); 
	}
	
	/**
	 * @return int count 返回HQL查询的记录数
	 * @param String HQL 统计的HQL语句
	*/
	public int getTotal() throws Exception {
		return ((Integer)super.getSession().createQuery("select count(*) from "+getTableName()).uniqueResult()).intValue();
	}
	
	/**
	 * @return String TableName
	 * */
	private String getTableName()throws Exception{
		return this.getClass().getName().substring(this.getClass().getName().lastIndexOf(".")+1, this.getClass().getName().length()-3);
	}
}


///这个是工具生成的修改了继承，使得为分页作准备。
public class UserinfoDAO extends AbsDao {}


//这个是伪泛型的DAO
public class DaoImpl extends AbsDao{
	/**
	 *@return List 以集合形式返回符合HQL语句中实体 
	 *@param String HQL  要执行的HQL语句
	 */
	public List getList(String HQL)throws Exception{
		return super.getHibernateTemplate().find(HQL);
	}
	
	/**
	 *将Object写入数据库 
	 *@param Object o  要保存的对象
	 */
	public void save(Object o)throws Exception{
		super.getHibernateTemplate().save(o);
	}
	
	/**
	 *将List(Object)写入数据库 
	 *@param List list(Object)  要保存的对象数组列表
	 */
	public void saveAll(List list)throws Exception{
		super.getHibernateTemplate().save(list);
	}
	
	/**
	 *将Object更新 
	 *@param Object o  要跟新的对象
	 */
	public void update(Object o)throws Exception{
		super.getHibernateTemplate().update(o);
	}
	
	
	/**
	 *将Object更新 
	 *@param List list(Object)  要更新的对象数组列表
	 */
	public void updateAll(List list)throws Exception{
		super.getHibernateTemplate().update(list);
	}
	

	/**通过SQL语句直接操作数据库
	 * @param String HQL;
	*/
	public void excuteSQL(String HQL) throws Exception {
		super.getHibernateTemplate().find(HQL);
	}

}

public interface PageService{
	public abstract int getPageSize()throws Exception;
	public abstract void setPageSize(int pageSize)throws Exception;

	public abstract int getTotal() throws Exception;
	public abstract int getPageCount()throws Exception;
	public abstract List getFirstPage() throws Exception;
	public abstract List getLastPage() throws Exception;
	public abstract List getPreviousPage(int currentPage)throws Exception;
	public abstract List getNextPage(int currentPage)throws Exception;
	public abstract List getPointPage(int pointPage)throws Exception;

}

public abstract class AbsPageService implements PageService {
	/**
	 * @return int 数据库中记录总数
	 * */
	public int getTotal() throws Exception {
		return getDao().getTotal();
	}
	
	/**
	 *@return int totalpage 返回分页数 
	 *@param int PageSize 页面的记录数
	 */
	public int getPageCount(int PageSize) throws Exception {
		return ((getTotal()+PageSize)-1)/PageSize;
	}

	/**
	 *@return List 返回指定页面的记录  注意这个方法提供给接口方法
	 *@param int PointPage 指定的页面
	 *@param int PageSize 页面的记录数
	 */
	public List getPointPage(int PointPage, int PageSize) throws Exception {
		if(PointPage>=0&&PointPage<=getPageCount(PageSize)){
			return getDao().getList((PointPage-1)*PageSize, PageSize);
		}
		else{
			return null;
		}
	}
	
	//以下是接口方法
	/**
	 *@return List 返回第一页的记录
	 **/
	public List getFirstPage() throws Exception{
		return this.getPointPage(1, PageSize);
	}
	
	/**
	 * @return List 返回最后一页
	 * */
	public List getLastPage() throws Exception{
		return this.getPointPage(this.getPageCount(PageSize), PageSize);
	}
	
	/**
	 * @return List 返回前一页的数据
	 * @param int currentPage 当前页
	 * */
	public List getPreviousPage(int currentPage)throws Exception{
		if(currentPage>1&&this.getTotal()>currentPage){
			return this.getPointPage(currentPage-1, PageSize);
		}
		else{
			return null;
		}
	}
	
	/**
	 * @return List 返回后一页的数据
	 * @param int currentPage 当前页
	 * */
	public List getNextPage(int currentPage)throws Exception{
		if(this.getTotal()>=(currentPage+1)&&(currentPage+1)>0){
			return this.getPointPage(currentPage+1, PageSize);
		}
		else{
			return null;
		}
	}
	
	/**
	 * @return List 返回当前页的数据
	 * @param int currentPage 当前页
	 * */
	public List getPointPage(int pointPage)throws Exception{
		if(this.getTotal()>=(pointPage)&&(pointPage)>0){
			return this.getPointPage(pointPage, PageSize);
		}
		else{
			return null;
		}
	}
	
	/**
	 * @return int 总页面数
	 * */
	public int getPageCount() throws Exception {
		return this.getPageCount(this.getPageSize());
	}
	//注入方法
	public int getPageSize() {
		return PageSize;
	}

	public void setPageSize(int pageSize) {
		PageSize = pageSize;
	}
	
	public Dao getDao() {
		return dao;
	}

	public void setDao(Dao dao) {
		this.dao = dao;
	}
	
	private int PageSize=10;
	private Dao dao;
}

public interface UserinfoService {
	public abstract void regist(Userinfo ui)throws Exception;
	public abstract void delete(Integer userinfoid)throws Exception;
	public abstract void update(Userinfo ui)throws Exception;
	public abstract Map manager(String pointPage,String operator)throws Exception;
	public abstract Userinfo find(Integer userinfoid)throws Exception;
	
}

public class UserinfoServiceImpl extends AbsPageService implements PageService,UserinfoService{
	/**
	 * 用户的删除方法
	 * @param Integer userinfoid
	 * */
	public void delete(Integer userinfoid) throws Exception {
		((UserinfoDAO)super.getDao()).delete(((UserinfoDAO)super.getDao()).findById(userinfoid));
	}
	
	/**
	 * 用户的查找方法
	 * @return Userinfo
	 * @param Integer userinfoid
	 * */
	public Userinfo find(Integer userinfoid) throws Exception {
		return ((UserinfoDAO)super.getDao()).findById(userinfoid);
	}
	
	/**
	 * 用户的管理方法
	 * @param String pointPage 当前页
	 * @param String operator 操作
	 * */
	public Map manager(String pointPage,String operator) throws Exception {
		this.setAph(new PageHold());
		this.getAph().setPs(this);
		return this.getAph().getUpsPage(pointPage, operator);
	}

	/**
	 * 用户的注册方法
	 * @param Userinfo userinfo
	 * */
	public void regist(Userinfo ui) throws Exception {
		((UserinfoDAO)super.getDao()).save(ui);		
	}

	/**
	 * 用户的更新方法
	 * @param Userinfo userinfo
	 * */
	public void update(Userinfo ui) throws Exception {
		((UserinfoDAO)super.getDao()).merge(ui);		
	}
	
	public AbsPageHold getAph() {
		return aph;
	}

	public void setAph(AbsPageHold aph) {
		this.aph = aph;
	}
	
	private AbsPageHold aph;

}

public abstract class AbsPageHold {
	/**
	 * 获取页面的逻辑
	 * @return Map map
	 * @param String pointPage 当前页
	 * @param String operator 操作符 
	 * */
	public Map getUpsPage(String pointPage,String operator)throws Exception{
		Map map=null;
		try{
			if(operator==null){
				map=this.getFirstPage();
			}
			else if(operator.equals("first")){
				map=this.getFirstPage();
			}
			else if(operator.equals("previous")){
				map=this.getPreviousPage(pointPage);
			}
			else if(operator.equals("next")){
				map=this.getNextPage(pointPage);
			}
			else if(operator.equals("jump")){
				map=this.getJumpPage(pointPage);
			}
			else if(operator.equals("last")){
				map=this.getLastPage();
			}
			else{
				map=this.getFirstPage();
			}
		}
		catch(Exception e){
			System.out.println(e);
		}
		return map;
	}
	
	/**
	 * 分页所需要的帮助类
	 * */
	public Map getMap()throws Exception{
		Map map=new HashMap();
		map.put("totalCount",new Integer(this.getPs().getTotal()));
		map.put("totalPage", new Integer(this.getPs().getPageCount()));
		return map;
	}
	
	//模板方法
	public abstract Map getFirstPage()throws Exception;
	public abstract Map getLastPage()throws Exception;
	public abstract Map getNextPage(String pointPage)throws Exception;
	public abstract Map getPreviousPage(String pointPage)throws Exception;
	public abstract Map getJumpPage(String pointPage)throws Exception;
	
	//注入 
	public PageService getPs() {
		return ps;
	}
	public void setPs(PageService ps) {
		this.ps = ps;
	}
	private PageService ps;
}

public class PageHold extends AbsPageHold{
	
	public Map getFirstPage() throws Exception {
		Map map=super.getMap();
		map.put("pointPage", "1");
		map.put("list", this.getPs().getFirstPage());
		return map;
	}

	public Map getJumpPage(String pointPage) throws Exception {
		Map map=super.getMap();
		int i=Integer.parseInt(pointPage);
		List list=this.getPs().getPointPage(i);
		if(list!=null){
			map.put("pointPage", ""+(i));
			map.put("list", list);
		}
		else{
			map.put("pointPage", "1");
			map.put("list", this.getPs().getFirstPage());
		}
	
		return map;
	}

	public Map getLastPage() throws Exception {
		Map map=super.getMap();
		map.put("pointPage",((Integer)map.get("totalPage")).toString());
		map.put("list",this.getPs().getLastPage());
		return map;
	}


	public Map getNextPage(String pointPage) throws Exception {
		Map map=super.getMap();
		int i=Integer.parseInt(pointPage);
		List list=this.getPs().getNextPage(i);
		if(list!=null){
			map.put("pointPage", ""+(i+1));
			map.put("list", list);
		}
		else{
			map.put("pointPage", ""+this.getPs().getPageCount());
			map.put("list", this.getPs().getLastPage());
		}
	
		return map;
	}

	public Map getPreviousPage(String pointPage) throws Exception {
		Map map=super.getMap();
		int i=Integer.parseInt(pointPage);
		List list=this.getPs().getPreviousPage(i);
		if(list!=null){
			map.put("pointPage", ""+(i-1));
			map.put("list", list);
		}
		else{
			map.put("pointPage", "1");
			map.put("list",this.getPs().getFirstPage());	
		}
		return map;
	}

}
。

• 搜狐网站诚聘Java、PHP和C++工程师
• 北京: 千橡集团暨校内网诚聘软件研发工程师

Pair<String, String> getFooAndBar() {
  ...
}

class FooAndBar {
  private final String foo;
  private final String bar;

  FooAndBar(String foo, String bar) {...}

  public String getFoo() {
    return foo;
  }

  public String getBar() {
    return bar;
  }
}

• 北京: 千橡集团暨校内网诚聘软件研发工程师
• 搜狐网站诚聘Java、PHP和C++工程师

• 北京: 千橡集团暨校内网诚聘软件研发工程师
• 搜狐网站诚聘Java、PHP和C++工程师

如题，不知道有的大型网站如何做的缓存，在页面上是如何显示个性化数据的[比如:登陆的动态信息]。

比如：淘宝，在它没一个商品页面都会有显示个性化数据[登陆信息:用户名，消息数量等的]，但是据我说知那页面肯定做了缓存的，要不然承受不了那么大的访问量。这就来问题了，居然做了缓存，为什么还能显示登陆信息？
1.假如是使用的cookie保存的个性化数据的，再从cookie里获取的信息显示到页面上，如果这个假如成立的话，那么从cookie里获取信息的话就只有两种方式：客户端和服务器端两种方式获取cookie信息，我看了下它的页面，没有找到任何使用客户端脚本获取cookie信息的代码。如果是从服务器端获取cookie信息的话那商品页面又如何能缓存呢？
2.假如是使用的session保存的个性化数据的，同上在服务器端读取cookie一样，页面又如何做到的缓存的？
3.难道是它只是针对未登陆用户做了缓存？不太可能，淘宝每天成交量都不低，故不太可能只针对登陆用户做缓冲。
4.难道是它使用了类似于oscache之类的缓存，页面中部分缓存，部分不缓存？


je也是同样的，如何即做到缓存又做到个性化数据的处理？

• 北京: 千橡集团暨校内网诚聘软件研发工程师
• 搜狐网站诚聘Java、PHP和C++工程师

• 北京: 千橡集团暨校内网诚聘软件研发工程师
• 搜狐网站诚聘Java、PHP和C++工程师

import java.awt.*;
import javax.swing.*;

public class TranslucentWindow extends JFrame {
	public TranslucentWindow() {
		super("Test translucent window");
		this.setLayout(new FlowLayout());
		this.add(new JButton("test"));
		this.add(new JCheckBox("test"));
		this.add(new JRadioButton("test"));
		this.add(new JProgressBar(0, 100));

		this.setSize(new Dimension(400, 300));
		this.setLocationRelativeTo(null);
		this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
	}

	public static void main(String[] args) {
		JFrame.setDefaultLookAndFeelDecorated(true);
		SwingUtilities.invokeLater(new Runnable() {
			public void run() {
				Window w = new TranslucentWindow();
				w.setVisible(true);

        //要使窗口透明，您可以使用 AWTUtilities.setWindowOpacity(Window, float) 方法
				com.sun.awt.AWTUtilities.setWindowOpacity(w, 0.5f);
			}
		});
	}

}

• 北京: 千橡集团暨校内网诚聘软件研发工程师
• 搜狐网站诚聘Java、PHP和C++工程师