@Override
public Exposer exportSeckillUrl(long seckillId) {
// Оптимизация точки: кеширование оптимизации: на основе тайм-аута для поддержания согласованности
//1. Доступ к Redis
Seckill seckill = redisDAO.getSeckill(seckillId);
if (seckill == null) {
//2. Доступ к базе данных
seckill = seckillDAO.queryById(seckillId);
if (seckill == null) {
return new Exposer(false, seckillId);
} else {
//3. Сохранение в Redis
redisDAO.putSeckill(seckill);
}
}

Date startTime = seckill.getStartTime();
Date endTime = seckill.getEndTime();
// Текущее время системы
Date nowTime = new Date();
if (nowTime.getTime() < startTime.getTime()
|| nowTime.getTime() > endTime.getTime()) {
return new Exposer(false, seckillId, nowTime.getTime(), startTime.getTime(),
endTime.getTime());
}
// Преобразование процесса конкретной строки, необратимое
String md5 = getMD5(seckillId);
return new Exposer(true, md5, seckillId);
}

package com.liushaoming.jseckill.backend.service.impl;

import com.google.common.util.concurrent.RateLimiter;
import com.liushaoming.jseckill.backend.service.AccessLimitService;
import org.springframework.stereotype.Service;

/**
 * Ограничение перед секундой-киллом.
 * Используется RateLimiter от Google guava
 */
@Service
public class AccessLimitServiceImpl implements AccessLimitService {
/**
* Каждые 10 токенов выдаются в секунду, и только запросы, получившие токены, могут войти в процесс секунды-килла
*/
private RateLimiter seckillRateLimiter = RateLimiter.create(10);

/**
* Попытка получить токен
* @return
*/
@Override
public boolean tryAcquireSeckill() {
return seckillRateLimiter.tryAcquire();
}
}

@Override
@Transactional
/**
* Выполнение секунды-килла
*/
public SeckillExecution executeSeckill(long seckillId, long userPhone, String md5) throws SeckillException {
if (accessLimitService.tryAcquireSeckill()) { // Если ограничение потока не применяется, выполнить обработку секунды-килла
return updateStock(seckillId, userPhone, md5);
} else { // Если применено ограничение потока, напрямую вызвать исключение ограничения доступа
logger.info("--->ACCESS_LIMITED-->seckillId={},userPhone={}", seckillId, userPhone);
throw new SeckillException(SeckillStateEnum.ACCESS_LIMIT);
}
}

@Override
    @Transactional
    /**
     * Сначала вставляем запись о мгновенной распродаже, затем уменьшаем количество товаров на складе
     */
    public SeckillExecution executeSeckill(long seckillId, long userPhone, String md5)
            throws SeckillException, RepeatKillException, SeckillCloseException {
        if (md5 == null || !md5.equals(getMD5(seckillId))) {
            logger.info("Данные о мгновенной распродаже были перезаписаны!!!. seckillId={},userPhone={}", seckillId, userPhone);
            throw new SeckillException("Данные о мгновенной распродаже были перезаписаны");
        }
        //Выполнение логики мгновенной распродажи: уменьшение количества товаров на складе + запись информации о покупке
        Date nowTime = new Date();

        try {
            //Запись информации о мгновенной распродаже (запись информации о покупке)
            int insertCount = successKilledDAO.insertSuccessKilled(seckillId, userPhone);
            //Уникальность: seckillId,userPhone
            if (insertCount <= 0) {
                //Повторная мгновенная распродажа
                logger.info("Мгновенная распродажа повторилась. seckillId={},userPhone={}", seckillId, userPhone);
                throw new RepeatKillException("Мгновенная распродажа повторилась");
            } else {
                //Уменьшение количества товаров на складе, конкуренция за горячие товары
                // reduceNumber - это операция обновления, которая активирует блокировку строки в таблице seckill
                int updateCount = seckillDAO.reduceNumber(seckillId, nowTime);
                if (updateCount <= 0) {
                    //Обновление записи не произошло, мгновенная распродажа завершена, откат
                    throw new SeckillCloseException("Мгновенная распродажа закрыта");
                } else {
                    //Мгновенная распродажа прошла успешно commit
                    SuccessKilled payOrder = successKilledDAO.queryByIdWithSeckill(seckillId, userPhone);
                    logger.info("Успех мгновенной распродажи->>>. seckillId={},userPhone={}", seckillId, userPhone);
                    //Завершение транзакции, снятие блокировки строки в таблице seckill
                    return new SeckillExecution(seckillId, SeckillStateEnum.SUCCESS, payOrder);
                }
            }
        } catch (SeckillCloseException e1) {
            throw e1;
        } catch (RepeatKillException e2) {
            throw e2;
        } catch (Exception e) {
            logger.error(e.getMessage(), e);
            //  Все исключения времени компиляции преобразуются в исключения времени выполнения
            throw new SeckillException("Внутренняя ошибка мгновенной распродажи:" + e.getMessage());
        }
    }

#Конфигурация Rabbitmq
rabbitmq.address-list=192.168.20.3:5672,localhost:5672
rabbitmq.username=myname
rabbitmq.password=somepass
rabbitmq.publisher-confirms=true
rabbitmq.virtual-host=/vh_test
rabbitmq.queue=seckill

rabbitmq.address-list=192.168.20.3:5672,localhost:5672

com.rabbitmq.client.ConnectionFactory#newConnection(List<Address> addrs) throws IOException, TimeoutException {}

@Bean("mqConnectionSeckill")
    public Connection mqConnectionSeckill(@Autowired MQConfigBean mqConfigBean) throws IOException, TimeoutException {
        ConnectionFactory factory = new ConnectionFactory();
        //Имя пользователя
        factory.setUsername(username);
        //Пароль
        factory.setPassword(password);
        //Путь виртуального хоста (аналогично имени базы данных)
        factory.setVirtualHost(virtualHost);
        //Возвращаем соединение
        return factory.newConnection(mqConfigBean.getAddressList());
    }