- 浏览: 214137 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
a66756675:
...
tomcat:tomcat的OutOfMemoryError解决 -
ooo456mmm:
说的对,如果用Mina框架来处理,要简单很多了
NIO socket服务器注意的几点. -
long_ltoy:
这样的话,看上去是代替了session,但这不和session ...
在JSP中使用JAVABEAN代替Session -
linzx0212:
关注下,不错……
tomcat:tomcat的OutOfMemoryError解决 -
liudeh_009:
总结得很好
NIO socket服务器注意的几点.
-- 发布时间:2005-10-20 22:06:01
-- 计数器系统
有一计数器系统要求如下:
1性能要求:每天访问量要求符合100000/天 且有30-40 个站点统计 同时进行
2刷新量,纯IP统计(0-24 每个时间段内)各自形成每天报表
本人的解决方案:
第一次读数据库,之后的数据都存在APLICATION中进行加一操作定时更新数据库 三四十个站点同时进行。
问题:发现Aplication 有不稳定的情况(同一Aplication 有时候一会儿变成这个数据 一会儿变成那个数据,之间的差值会虽时间长而变大,但是还是最大的那个正确,就是检查不出来怀疑数据访问量大的时候Tomcat 没有处理好Aplication这个东西)如果把这个程序单独每个统计站布署一个就不会出现这种情况。注:我的程序不存在性能瓶经基本全在内存中操作速度很快服务器硬件也没有问题。
谁能用JAVA来实现统一计数实现我如上的条件,或者能解决一下我的问题所在,本人将以高分数表示感谢,希望写过大型计数器的朋友进入
本人写了一个Servlet 不怕大家见笑抛砖引玉:
以下是本人前100行代码(程序有不完善的地方见笑。。。)
import java.sql.*;
import javax.sql.*;
import javax.servlet.*;
import javax.servlet.http.*;
import javax.servlet.jsp.PageContext;
import java.io.*;
import java.util.Date;
import java.text.DateFormat;
import com.inberkong.util.DataBaseConnection;
public class CounterServlet extends HttpServlet
{
private String counterSite;
//private int count=0;
private Connection con=null;
private String pString ="";
private final int WRITE_TIME=6;//定时写数据库的间隔时长以秒为单位
private ServletContext application=null;
public void doGet(HttpServletRequest request,
HttpServletResponse response)
throws IOException, ServletException
{
response.setContentType("text/html;charset=gb2312");
String theIP=request.getRemoteAddr();//得到访问者IP;
Date time1=new java.util.Date();//获得系统当前时间
String Referer=request.getHeader("Referer");//得到来访者地址
if(Referer==null)
{
System.out.print("No Referer value");
}
// String Referer="http://61.163.234.223/zhaotie/test1.htm";//\' target="_blank" >http://61.163.234.223/zhaotie/test1.htm";//摸拟得到来访者地址(检验数据开始要把此项打开)
String [] siteAddress=Referer.split("/");
counterSite=siteAddress[0]+"//"+siteAddress[2];//得到来访者的网址域名
PrintWriter out =response.getWriter();
String sql="";
Date tm=new java.util.Date();//获得系统当前时间
String sqltm=new Timestamp(tm.getTime()).toString();//将当前时间转换成sql server可以识别的对象
String st2=sqltm;
st2=st2.substring(0,19);//2005-08-14 18:41:33
String d1=st2.substring(0,10);
application = getServletConfig().getServletContext();
try
{
if(application.getAttribute(counterSite+"_checkAccount")==null)//初始计数器的状态.
{
//application.setAttribute(counterSite,new Integer(count));//计数器
Statement stmt=null;
try{
//如果数据库缓冲池无连接则重新启动TOMCATE服务
stmt=con.createStatement();
}catch(SQLException ee)
{
destroy();
Runtime rn=Runtime.getRuntime();
Process p=null;
try{
p=rn.exec("tomcat5.exe stop");
for(int i=0;i<1999999999;i++)
{
;
}
p=rn.exec("taskkill /F /IM tomcat5w.exe /T");
p=rn.exec("taskkill /F /IM tomcat5.exe /T");
for(int j=0;j<1999999999;j++)
{
;
}
p=rn.exec("tomcat5.exe start");
}catch(Exception e){
System.out.println("Error exec notepad");
}
以下为101-200行代码
System.out.print(ee+""+new java.util.Date());
}
ResultSet rs=null;
application.setAttribute(counterSite+"Date1",new java.util.Date());//站点定时时间
sql="select id,R_TODAY_SUM,R_TOM_SUM,R_THIS_MONTH_SUM,R_TOTAL_SUM,R_TOTAL_DAY,R_COUNT_DATE from inber_count_account where ACCOUNT_SIT_ADD like \'%"+counterSite+"%\'";
//out.print(sql);
rs=stmt.executeQuery(sql);
if(rs.next())
{
application.setAttribute(counterSite+"_checkAccount",new String("ok"));
application.setAttribute(counterSite+"_id",new Integer(rs.getInt(1)));
application.setAttribute(counterSite+"_R_TODAY_SUM",new Integer(rs.getInt(2)));
application.setAttribute(counterSite+"_R_TOM_SUM",new Integer(rs.getInt(3)));
application.setAttribute(counterSite+"_R_THIS_MONTH_SUM",new Integer(rs.getInt(4)));
application.setAttribute(counterSite+"_R_TOTAL_SUM",new Integer(rs.getInt(5)));
application.setAttribute(counterSite+"_R_TOTAL_DAY",new Integer(rs.getInt(6)));
//****
application.setAttribute(counterSite+"_R_COUNT_DATE",new String(rs.getString("R_COUNT_DATE")));
}
rs.close();
stmt.close();
}
else
{
if((application.getAttribute(counterSite+"_checkAccount").toString()).equals("ok"))//校验此计数器账号引用是否存在
{
Date accessTime=null;
//刷新率 start----------------------------------
application.setAttribute(counterSite+"_R_TODAY_SUM",new Integer(Integer.parseInt((application.getAttribute(counterSite+"_R_TODAY_SUM").toString()))+1));
application.setAttribute(counterSite+"_R_THIS_MONTH_SUM",new Integer(Integer.parseInt((application.getAttribute(counterSite+"_R_THIS_MONTH_SUM").toString()))+1));
application.setAttribute(counterSite+"_R_TOTAL_SUM",new Integer(Integer.parseInt((application.getAttribute(counterSite+"_R_TOTAL_SUM").toString()))+1));
String d2=application.getAttribute(counterSite+"_R_COUNT_DATE").toString();
//当日期改变时,清除当天的计数
String tYear,tMonth,tDay;
tYear=d2.substring(0,4);
tMonth=d2.substring(5,7);
tDay=d2.substring(8,10);
if(!(d1.equals(d2)))
{
int todaysum=Integer.parseInt((application.getAttribute(counterSite+"_R_TODAY_SUM").toString()));
int totalday=Integer.parseInt((application.getAttribute(counterSite+"_R_TOTAL_DAY").toString()));
application.setAttribute(counterSite+"_R_TOM_SUM",new Integer(todaysum));
application.setAttribute(counterSite+"_R_TODAY_SUM",new Integer(0));
application.setAttribute(counterSite+"_R_TOTAL_DAY",new Integer(totalday+1));
application.setAttribute(counterSite+"_R_COUNT_DATE",new String(d1));
try{
CallableStatement cstmt4=null;
pString = "{call p_setDetailList3(\'"+tYear+"\', \'"+tMonth+"\', \'"+tDay+"\',"+todaysum+", \'"+d2+"\',"+Integer.parseInt((application.getAttribute(counterSite+"_id").toString()))+")}";
cstmt4=con.prepareCall(pString);
cstmt4.executeUpdate();
cstmt4.close();
}
catch(Exception ee)
{
System.out.println("call p_setDetailList3 is wrong:"+ee);
}
}
String cMonth=d1.substring(5,7);
//当月改变时清除当月的计数,并计数当月第一个浏览者.
if(!(cMonth.equals(tMonth)))
{
application.setAttribute(counterSite+"_R_THIS_MONTH_SUM",new Integer(0));
application.setAttribute(counterSite+"_R_COUNT_DATE",new String(d1));
}
//刷新率 end----------------------------------
201-3百行以后的代码
//count=Integer.parseInt((application.getAttribute(counterSite).toString()));
////////////////////////////////////////////定时写数据库同时 初始化数据 start/////////
Date time2=new java.util.Date();//获得系统当前时间
Date t1=(Date)application.getAttribute(counterSite+"Date1");
int secondValue=(int)(((double)time2.getTime()-(double)t1.getTime())/1000);
if(secondValue>=WRITE_TIME)//
{//定时写数据库同时 初始化数据
int siteid=Integer.parseInt((application.getAttribute(counterSite+"_id").toString()));
int a1=Integer.parseInt((application.getAttribute(counterSite+"_R_TODAY_SUM").toString()));
int a2=Integer.parseInt((application.getAttribute(counterSite+"_R_TOM_SUM").toString()));
int a3=Integer.parseInt((application.getAttribute(counterSite+"_R_THIS_MONTH_SUM").toString()));
int a4=Integer.parseInt((application.getAttribute(counterSite+"_R_TOTAL_SUM").toString()));
int a5=Integer.parseInt((application.getAttribute(counterSite+"_R_TOTAL_DAY").toString()));
String a6=application.getAttribute(counterSite+"_R_COUNT_DATE").toString();
try{
CallableStatement cstmt5=null;
pString = "{call p_INBER_COUNT_ACCOUNT_EDIT2("+siteid+","+a1+","+a2+","+a3+","+a4+","+a5+",\'"+a6+"\')}";
cstmt5=con.prepareCall(pString);
cstmt5.executeUpdate();
cstmt5.close();
}
catch(Exception ee)
{
System.out.println("call p_INBER_COUNT_ACCOUNT_EDIT2 is wrong:"+ee);
}
//count=0;
//application.setAttribute(counterSite,new Integer(count));//得到初始值,
application.setAttribute(counterSite+"Date1",new java.util.Date());//初始时间为系统当前时间
//application.setAttribute(counterSite,new Integer(count));//计数器
////////////////////////////////////////////定时写数据库同时 初始化数据 end//////////////////
}
//////////////检验数据2开始///////////////////////////////////////////////////////////
/*out.print("secondValue="+secondValue+"<BR>");
out.print("counter="+count+"<BR>"+"counterSite="+counterSite+"<BR>");
*/
//////////////检验数据2结束///////////////////////////////////////////////////////////
}
else
{//校验此计数器账号引用是否存在
}
}
//System.out.println(count+":"+counterSite+" "+theIP);
// count++;
//application.setAttribute(counterSite,new Integer(count));
} catch(SQLException e)
{
System.out.println("cc:"+e);
}
out.close();
}
/**
*处理Post请求
*/
/**
*获得初始化参数
*/
public void init() throws ServletException
{
try{
int ss=0;
con=DataBaseConnection.getConnection();
}
catch (Exception e)
{
System.out.println("Error(con error):"+e);
}
}
public void destroy()
{
int siteid=Integer.parseInt((application.getAttribute(counterSite+"_id").toString()));
int a1=Integer.parseInt((application.getAttribute(counterSite+"_R_TODAY_SUM").toString()));
int a2=Integer.parseInt((application.getAttribute(counterSite+"_R_TOM_SUM").toString()));
int a3=Integer.parseInt((application.getAttribute(counterSite+"_R_THIS_MONTH_SUM").toString()));
int a4=Integer.parseInt((application.getAttribute(counterSite+"_R_TOTAL_SUM").toString()));
int a5=Integer.parseInt((application.getAttribute(counterSite+"_R_TOTAL_DAY").toString()));
String a6=application.getAttribute(counterSite+"_R_COUNT_DATE").toString();
try{
CallableStatement cstmt6=null;
pString = "{call p_INBER_COUNT_ACCOUNT_EDIT2("+siteid+","+a1+","+a2+","+a3+","+a4+","+a5+",\'"+a6+"\')}";
cstmt6=con.prepareCall(pString);
cstmt6.executeUpdate();
cstmt6.close();
System.out.println("when the programe stoped execute this code automatic!");
con.close();
}
catch (SQLException e)
{
System.out.println("desdory error:"+e);
}
}
}
=====================
天哪... 没看懂
大概你是遇上并发操作的问题了. 所有的应用服务器都有并发的问题, 主要还是看的应用怎么去处理了. 要注意一下几点
1. 数据库操作得用事务, 而且避免脏读. 如果想避免别人并发操作你的数据, 可以使用锁
2. 对象上注意是否线程安全, 避免多个线程同时写变量
3. 更新数据使用相对值, 不要用绝对值. 如: update table set a = a + @value where ...
100000/天访问不算大, 如果没有并发峰值限制. 不需要太特殊得处理方法
http://community.csdn.net/Expert/topic/4332/4332118.xml?temp=.1796991
发表评论
-
DHTML应用一撇改变网页中元素(Inber原作)
2004-08-19 12:00 798利用DHTML技术我们可以改变网页中的任何效果 (原理:首行读 ... -
windows下配置Apache支持PHP5
2004-09-16 17:43 16621在此之前先安装Apache然后再安装PHP5安装时选择apc ... -
搭建WAP应用开发环境 (转载)
2004-09-29 11:25 1005搭建WAP应用开发环境 ( ... -
我在思考一个问题:用纯dhtml技术来实现信息交流平台的应用.
2004-09-29 16:57 729一个偶然的时间让我这样的想法.有javascript +htm ... -
之控制表格的字数的处理方法.
2004-10-09 16:21 827<td class=v ... -
知道吗,生意通常都是这样谈成的
2005-12-16 15:14 697一位优秀的商人杰克,有一天告诉他的儿子 杰克:我已经决定好了一 ... -
当你不需要再重复以前工作的时候你该考虑做些什么?
2005-12-22 13:20 655对于我来说争取每个项目的成功施使的目的在于获得更多的项目开发经 ... -
网络就是计算机
2006-01-02 17:39 657因为一些原因机器有一两个月没有上网了,机器一直放在角落没再碰过 ... -
利用现有资源建立自己的经营模式
2006-09-05 09:45 735兴趣和爱好是一个人一生中所要经营的东西,如果能以现有的资 ... -
25年:两个错误的预言
2007-07-13 09:11 75625年:两个错误的预言 1 ...
相关推荐
【个人博客】 Java、技术面试必备基础知识、Leetcode、计算机操作系统、计算机网络等_CSLearning
yolo系列算法目标检测数据集,包含标签,可以直接训练模型和验证测试,数据集已经划分好,适用yolov5,yolov8,yolov9,yolov7,yolov10,yolo11算法; 包含两种标签格:yolo格式(txt文件)和voc格式(xml文件),分别保存在两个文件夹中; yolo格式:<class> <x_center> <y_center> <width> <height>, 其中: <class> 是目标的类别索引(从0开始)。 <x_center> 和 <y_center> 是目标框中心点的x和y坐标,这些坐标是相对于图像宽度和高度的比例值,范围在0到1之间。 <width> 和 <height> 是目标框的宽度和高度,也是相对于图像宽度和高度的比例值
那些年,与你同分同位次的同学都去了哪里?全国各大学在四川2020-2024年各专业最低录取分数及录取位次数据,高考志愿必备参考数据
人力资源+大数据+薪酬报告+涨薪调薪,在学习、工作生活中,越来越多的事务都会使用到报告,通常情况下,报告的内容含量大、篇幅较长。那么什么样的薪酬报告才是有效的呢?以下是小编精心整理的调薪申请报告,欢迎大家分享。相信老板看到这样的报告,一定会考虑涨薪的哦。
那些年,与你同分同位次的同学都去了哪里?全国各大学在四川2020-2024年各专业最低录取分数及录取位次数据,高考志愿必备参考数据
这是一个基于全卷积神经网络的语音识别系统_DFCNN-master
一个可以运行在 vercel 上的 go 语言框架,基于 g
基于一维卷积神经网络(1D-CNN)的多元时间序列分类_TSC-CNN
网鼎杯
那些年,与你同分同位次的同学都去了哪里?全国各大学在四川2020-2024年各专业最低录取分数及录取位次数据,高考志愿必备参考数据
那些年,与你同分同位次的同学都去了哪里?全国各大学在四川2020-2024年各专业最低录取分数及录取位次数据,高考志愿必备参考数据
那些年,与你同分同位次的同学都去了哪里?全国各大学在四川2020-2024年各专业最低录取分数及录取位次数据,高考志愿必备参考数据
OrinNX平台JetPack 5.1.4-R35.6.0版本相机相关补丁1
MD5EditTools,MD5修改工具.exe
原文链接:https://blog.csdn.net/zsd12379/article/details/141281454 包含功能: 业主管理:实现业主信息的录入、编辑、查询与删除,确保业主数据的准确性和完整性。 维修员管理:管理维修员的基本信息、工作状态和派工情况,优化维修资源配置。 楼宇信息管理:记录并维护楼宇的基本信息、设施详情及状态,支持快速查询与更新。 业主投诉管理:接收并处理业主的投诉信息,跟踪处理进度,提升业主满意度。 业主报修管理:提供便捷的报修渠道,记录报修详情,实现报修请求的有效管理。 报修处理管理:分配报修任务给维修员,跟踪报修进度,确保报修问题及时解决。 缴费信息管理:管理业主的缴费记录,包括物业费、维修基金等,支持费用查询与提醒。 建议反馈管理:收集业主的建议与反馈,促进物业服务的持续改进和优化。
<项目介绍> - 该项目是为了研究基于深度卷积神经网络的图像去噪算法,是利用DnCNN模型,但是为了比较该算法的效果,另外实现了四种传统的图像去噪算法(均值滤波、中值滤波、非局部均值滤波NLM和三维块匹配滤波BM3D)作为对照组 - 不懂运行,下载完可以私聊问,可远程教学 该资源内项目源码是个人的毕设,代码都测试ok,都是运行成功后才上传资源,答辩评审平均分达到96分,放心下载使用! 1、该资源内项目代码都经过测试运行成功,功能ok的情况下才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.md文件(如有),仅供学习参考, 切勿用于商业用途。 --------
2023-04-06-项目笔记-第三百零三阶段-课前小分享_小分享1.坚持提交gitee 小分享2.作业中提交代码 小分享3.写代码注意代码风格 4.3.1变量的使用 4.4变量的作用域与生命周期 4.4.1局部变量的作用域 4.4.2全局变量的作用域 4.4.2.1全局变量的作用域_1 4.4.2.301局变量的作用域_301- 2024-10-31
那些年,与你同分同位次的同学都去了哪里?全国各大学在四川2020-2024年各专业最低录取分数及录取位次数据,高考志愿必备参考数据
High_net_worth.dta