最好不要用java写秒杀器，因为你就算用 httpclient 拿到的也是未经过渲染的html页面，很多页面js都没有加载，你根本不知道渲染之后的页面长什么样子，你最好学学木鱼的火车票抢票助手，他用的是 firefox 的插件 scriptish 来写抢票脚本，其实抢票跟秒杀是一个原理的，我第一个秒的程序就是照着他的程序改的，用这个上手也比较容易，但是要求你对javascript比较熟悉，不过比用java实现靠谱多了
十余年的和平网站建设经验，针对设计、前端、开发、售后、文案、推广等六对一服务，响应快，48小时及时工作处理。营销型网站的优势是能够根据用户设备显示端的尺寸不同，自动调整和平建站的显示方式，使网站能够适用不同显示终端，在浏览器中调整网站的宽度，无论在任何一种浏览器上浏览网站，都能展现优雅布局与设计，从而大程度地提升浏览体验。创新互联从事“和平网站设计”,“和平网站推广”以来，每个客户项目都认真落实执行。
import java.util.Scanner;
/**
* @author a href="mailto:116982086@qq.com"/a
*/
public class Demo {
public static void main(String[] args) {
Scanner scanner = new Scanner(System.in);
System.out.println("请输入消费金额");
double sum = scanner.nextDouble();
String what = null;
// 如果消费金额大于50才提示换购
if (sum = 50) {
System.out.println("是否参加优惠换购活动：");
System.out.println("1:满50元,加2元换购百事可乐饮料一瓶");
if (sum = 100) {
System.out.println("2:满100元,加3元换购500ml可乐一瓶");
System.out.println("3:满100元,加3元换购500ml可乐一瓶");
}
if (sum = 200) {
System.out.println("4:满200元,加10元可换购1歌苏泊尔炒菜锅");
System.out.println("5:满200元,加20元可换购欧莱雅爽肤水一瓶");
}
System.out.println("0:不换购");
System.out.println("请选择:");
int choice = scanner.nextInt();
int add = 0;
switch (choice) {
case 1:
add = 2;
what = "500ml可乐一瓶";
break;
case 2:
add = 3;
what = "500ml可乐一瓶";
break;
case 3:
add = 3;
what = "5公斤面粉";
break;
case 4:
add = 10;
what = "一个歌苏泊尔炒菜锅";
break;
case 5:
add = 20;
what = "欧莱雅爽肤水一瓶";
break;
default:
break;
}
sum += add;
}
System.out.println("本次消费总金额: " + sum);
if (null != what) {
System.out.println("成功换购 " + what);
}
}
}
public class Lucky {
public static void main(String[] args){
System.out.println("请输入您的4位会员卡号:");
Scanner sc = new Scanner(System.in);
int number = sc.nextInt(); //接收用户从控制台输入的会员卡号，并保存在会员卡号变量中
int a = number/1000; //千位
int b = number%1000/100; //百位
int c = number%100/10; //十位
int d = number%10; //个位
if((a+b+c+d)20){
System.out.println("恭喜中奖!您是幸运客户");
}else{
System.out.println("谢谢参与!");
}
}
}
最基础的 没有异常判断 无限循环输入什么东西
不考虑多服务器，限制线程池的大小和队列的限制来实现。
代码如下：
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;
}
}
import java.util.Timer;
import java.util.TimerTask;
public class Test extends TimerTask {
public static void main(String[] args) {
Timer timer = new Timer();
Test t=new Test();
//程序运行后立刻执行任务，每隔1000ms执行一次
timer.schedule(t, 0, 1000);
}
@Override
public void run() {
System.out.println("在此处调用插入数据库的方法");
}
}
首先说 队列这种数据结构你应该了解吧 。
可以用JDK自带的 或者自己实现的也行，你问的如何实现队列是指的队列这中数据结构？ 如果是 ，那你还是自己看数据结构那本书，原理都一样 跟语言无关， 你可用JDK自带的几种队列 查看JDKAPI文档 实现了Queue接口的各种队列基本都有，比如 线程安全的 ConcurrentLinkedQueue 这个是一个无界的线程安全的队列 或者 ArrayBlockingQueue 这个队列实现是一个有界阻塞队列 都能够实现你说的 或者 你用非线程安全的也成 只不过你自己控制线程的安全性就好了；.