重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
不考虑多服务器,限制线程池的大小和队列的限制来实现。
我们提供的服务有:网站设计、做网站、微信公众号开发、网站优化、网站认证、石峰ssl等。为千余家企事业单位解决了网站和推广的问题。提供周到的售前咨询和贴心的售后服务,是有科学管理、有技术的石峰网站制作公司
代码如下:
package org.zhang;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.Executors;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
/**
* 单服务器用线程池实现秒杀的思路一
*
* @author zhanghaijun
*
*/
public class ExecutorsTest {
public static boolean flag = true; // 秒杀物品的标记
public static void main(String[] args) {
ThreadPoolExecutor pool = new ThreadPoolExecutor(1, 1, 0L,
TimeUnit.MILLISECONDS, new SynchronousQueueRunnable());
ThreadTest t1 = new ThreadTest("张三");
ThreadTest t2 = new ThreadTest("李四");
ThreadTest t3 = new ThreadTest("王五");
try {
pool.execute(t1);
} catch (Exception e) {
System.out.println(t1.getUserName() + "没有抢到");
}
try {
pool.execute(t3);
} catch (Exception e) {
System.out.println(t3.getUserName() + "没有抢到");
}
try {
pool.execute(t2);
} catch (Exception e) {
System.out.println(t2.getUserName() + "没有抢到");
}
pool.shutdown();
}
}
class ThreadTest extends Thread {
private String userName;
public ThreadTest(String userName) {
super();
this.userName = userName;
}
@Override
public void run() {
try {
Thread.sleep(200);
if (ExecutorsTest.flag) {
System.out.println(this.userName + "秒杀成功");
ExecutorsTest.flag = false;
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
}
用redis,比如秒杀一个商品,把该商品的信息放在redis中,主要是那个库存量,抢购的时候在redis中操作数据非常快,每秒差不多8万次读写操作,这样的并发量已经够用了
write后调用close来保存文件内容,因为是写到缓冲区,并没真正写入文件系统。
close后,需要重新打开文件,这次以r模式打开即可,调用readInt,就没问题。
最好不要用java写秒杀器,因为你就算用 httpclient 拿到的也是未经过渲染的html页面,很多页面js都没有加载,你根本不知道渲染之后的页面长什么样子,你最好学学木鱼的火车票抢票助手,他用的是 firefox 的插件 scriptish 来写抢票脚本,其实抢票跟秒杀是一个原理的,我第一个秒的程序就是照着他的程序改的,用这个上手也比较容易,但是要求你对javascript比较熟悉,不过比用java实现靠谱多了