作者 王勇

再次对增加队列时,增添验证

... ... @@ -116,7 +116,6 @@ public class BusQueueController {
public ResultJson insertBusQueue(@RequestBody BusQueue busQueue) throws IOException, TimeoutException
{
String message = validateBusQueue(busQueue);
//验证通过
return message == null
? busQueueService.insertSelective(busQueue)
... ...
0、首先要有rabbitmq服务器以及对应的虚拟主机
1、要有交换机 exchange
2、要有队列 queue
3、要有队列、交换机、路由键的绑定关系 binding
4、才能将消息发送到 exchange,从exchange分发到queue,从queue处接收到消息,进行消息的消费(具体业务)
从exchange分发到queue,是通过 routingkey
\ No newline at end of file
... ... @@ -112,10 +112,10 @@ public class BusQueueServiceImpl implements BusQueueService {
public ResultJson insertSelective(BusQueue record) throws IOException, TimeoutException
{
if (userInfoMapper.selectUserExist(record.getUsername()).size() == 0) {
return new ResultJson<>("400", "该用户信息,不存在");
return new ResultJson<>("400", "该MQ用户信息,不存在");
}
if (userInfoMapper.selectByBusQueue(record).size() == 0) {
return new ResultJson<>("400", "该用户关系,不存在");
return new ResultJson<>("400", "该MQ用户关系,不存在");
}
// 设置id
record.setId(IdUtils.generateId());
... ...