
正文
java并发量代码 java 并发量
提示:扫一扫查出行【扫一扫了解最新限行尾号】
复制提示
只通过java代码,保证并发量过万的方法有哪些
另外一个回复是简单的建议,限于代码层面跟计算资源紧张的情况。
说说我的理论:
1、想要这么大的并发量,申请买几台比较好的机器,带宽加到足够大应该不是问题。
2、网络层的负载均衡考虑一下,这应该也不是啥问题,这么大并发量,别告诉我客户网络设计很垃圾。高端点的网络设备都没有。
3、软件层的结构,看用户给什么样的机器,如果经济型的机器,考虑分布式运算,分布式再从软件层面做集群或主从。根据计算密集型还是IO密集型选择适合的设备。计算密集型的业务,需要强悍的CPU(可以用多C,未必是频率高的)+内存。IO密集型的业务需要,速度快的存储,越快越好。有极致要求的考虑固态存储设备。
4、并发设计,java中主要是线程的应用。能拆分成多任务的运算一定拆成多任务。尽量压榨cpu资源,现在的工作站不会写并发程序,真浪费cpu资源。
5、数据库并发的考量,以前说mysql不如oracle现在还有人有这论调。使用的时候把参数调整到最优状态。如缓存到内存中数据大小,内存要够,就把全部表数据加载到内存中。mysql的innodb调整两三个参数就行。数据库IO访问,mysql有测算IO能力的参数,存储够好,可以调整到很大。
6、这么大的并发量,选择适合的缓存器,可以用来缓存热点数据,或加快分布式运算的IO访问能力。(磁盘肯定没内存块,包括固态)
7、代码编写完后,对系统整体进行测试,评估,分析性能瓶颈,优化代码。
能做到以上标准,tomcat+mysql跑一堆集群也不会慢。
相关问答
Q1: java代码的高并发怎么用
public class Test {
public static void main(String[] args) {
int count = 1000;
ExecutorService executorService = Executors.newFixedThreadPool(count);
for (int i = 0; i count; i++)
executorService.execute(new Test().new Task());
executorService.shutdown();
while (!executorService.isTerminated()) {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public class Task implements Runnable {
@Override
public void run() {
try {
// 测试内容
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
如果要实现真正的并发同时执行,可通过CyclicBarrier来控制。
public class Test {
public static void main(String[] args) {
int count = 1000;
CyclicBarrier cyclicBarrier = new CyclicBarrier(count);
ExecutorService executorService = Executors.newFixedThreadPool(count);
for (int i = 0; i count; i++)
executorService.execute(new Test().new Task(cyclicBarrier));
executorService.shutdown();
while (!executorService.isTerminated()) {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public class Task implements Runnable {
private CyclicBarrier cyclicBarrier;
public Task(CyclicBarrier cyclicBarrier) {
this.cyclicBarrier = cyclicBarrier;
}
@Override
public void run() {
try {
// 等待所有任务准备就绪
cyclicBarrier.await();
// 测试内容
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
Q2: java httpclient 并发量大怎么办
java httpclient 并发量大解决办法:
首先你要增加一个关于异步IO需要的包:
1、async-http-client包,可以在这里下载:
2、log4j的包,这个不用我说了,都知道在哪里
3、slf4j-spi 的包,目前用1.5以上的版本比较多。
4、slf4j-log4j 的包,可以看出,slf4j是在log4j基础上包装的。
OK,就这几个了,弄好后再看看下面这段代码,通过使用它,性能可以得到明显改善:
[java] view plain
AsyncHttpClient client = new AsyncHttpClient();
try {
FutureResponse f = client.prepareGet("").execute();
System.out.println(f.get().getResponseBody("Big5"));//谷歌的输出编码集为Big5,反向解析结果的时候使用
}catch(...) {....}
这段代码是不是超级简单,可以通过上面描述的三种方式:
1、直接调用
2、将GetMethod或PostMethod对象作为共享对象反复使用。
3、使用AsyncHttpClient
这三种方法,非别使用一次调用、循环多次调用、并发调用来测试性能,后面两者的性能比第一种方法的性能要高很多。
Q3: java 并发实现原理: 是否可以利用多线程,实现10个并发执行 请给个例子(java代码),非常感谢!!!!
public static void main(String[] args) {
for(Thread t:getThreads()){
t.start();
}
}
public static Thread[] getThreads(){
Thread[] thread = new Thread[10];
for(int i=0;i10;i++){
final Integer num = new Integer(i);
thread[i] = new Thread(new Runnable(){
public void run() {
int j=5;
while(j--0){
System.out.println("this is thread"+num);
}
}
});
}
return thread;
}
关于java并发量代码和java 并发量的介绍到此就结束了,不知道你从中找到你需要的信息了吗 ?如果你还想了解更多这方面的信息,记得收藏关注本站。








