JoyLau's Blog

@Data
@Component
@ConfigurationProperties(prefix = "ice")
public class Client {
    private String adapterName;
    private String host;
    private int port;

    private Logger _logger = LoggerFactory.getLogger(Client.class);

    /**
     * 执行操作
     *
     * @param command 命令体
     * @return Result
     */
    public Result execute(CommandBody command) {
        Ice.Communicator ic = null;
        try {
            //初使化通信器
            ic = Ice.Util.initialize();
            //传入远程服务单元的名称、网络协议、IP及端口，获取接口的远程代理，这里使用的stringToProxy方式
            Ice.ObjectPrx base = ic.stringToProxy(getStringProxy());
            //通过checkedCast向下转换，获取接口的远程，并同时检测根据传入的名称获取的服务单元是否代理接口，如果不是则返回null对象
            ZKRoadRangeAdminPrx interfacePrx = ZKRoadRangeAdminPrxHelper.checkedCast(base);
            if (interfacePrx == null) {
                return new Result(false, "Invalid proxy");
            }
            //把接口的方法传给服务端，让服务端执行
            Result result = executeCommand(command, interfacePrx);
            if (result == null) {
                return new Result(false, "暂无此操作命令");
            }
            return result;
        } catch (Exception e) {
            _logger.info(e.getMessage(), e);
            return new Result(false, "连接错误！" + e);
        } finally {
            if (ic != null) {
                ic.destroy();
            }
        }
    }

    /**
     * 执行操作命令
     *
     * @param command      命令体
     * @param interfacePrx 接口
     * @return ProgramResponse
     */
    private Result executeCommand(CommandBody command, ZKRoadRangeAdminPrx interfacePrx) {
        CommandType type = command.getCommandType();
        if (type.equals(CommandType.addRange)) {
            return returnMessage(interfacePrx.AddRange(command.getZkRoadRange()));
        } else if (type.equals(CommandType.updateRange)) {
            return returnMessage(interfacePrx.UpdateRange(command.getZkRoadRange()));
        } else if (type.equals(CommandType.removeRange)) {
            return returnMessage(interfacePrx.RemoveRange(command.getZkRoadRange().code));
        } else if (type.equals(CommandType.getRange)) {
            return new Result(true, JSONObject.toJSONString(interfacePrx.GetRange(command.getZkRoadRange().code)));
        } else if (type.equals(CommandType.listRanges)) {
            return new Result(true, JSONObject.toJSONString(interfacePrx.ListRanges()));
        }
        return null;
    }


    /**
     * 获取配置的地址信息
     *
     * @return String
     */
    private String getStringProxy() {
        return adapterName + ":tcp -h " + host + " -p " + port;
    }


    private Result returnMessage(boolean result) {
        return result ? new Result(true, "success") : new Result(false, "failure");
    }

}

@SpringBootApplication
@EnableSwagger2
public class JoylauSwagger2Application {

	public static void main(String[] args) {
		SpringApplication.run(JoylauSwagger2Application.class, args);
	}

	@Bean
	public Docket createRestApi() {
		return new Docket(DocumentationType.SWAGGER_2)
				.apiInfo(apiInfo())
				.select()
				.apis(RequestHandlerSelectors.basePackage("cn.joylau.code"))
				.paths(PathSelectors.any())
				.build();
	}

	private ApiInfo apiInfo() {
		return new ApiInfoBuilder()
				.title("Spring Boot构建RESTful APIs")
				.description("将每一个注解的@RestController和@ResponseBody的类和方法生成API，点击即可展开")
				.termsOfServiceUrl("http://blog.joylau.cn")
				.contact(new Contact("joylau","http://blog.joylau.cn","2587038142@qq.com"))
				.license("The Apache License, Version 2.0")
				.licenseUrl("http://www.apache.org/licenses/LICENSE-2.0.html")
				.version("1.0")
				.build();
	}
}

@RestController
@RequestMapping(value="/users")     // 通过这里配置使下面的映射都在/users下，可去除
public class UserController {

    static Map<Long, User> users = Collections.synchronizedMap(new HashMap<Long, User>());

    @ApiOperation(value="获取用户列表", notes="")
    @RequestMapping(value={""}, method= RequestMethod.GET)
    public List<User> getUserList() {
        List<User> r = new ArrayList<User>(users.values());
        return r;
    }

    @ApiOperation(value="创建用户", notes="根据User对象创建用户")
    @ApiImplicitParam(name = "user", value = "用户详细实体user", required = true, dataType = "User")
    @RequestMapping(value="", method=RequestMethod.POST)
    public String postUser(@RequestBody User user) {
        users.put(user.getId(), user);
        return "success";
    }

    @ApiOperation(value="获取用户详细信息", notes="根据url的id来获取用户详细信息")
    @ApiImplicitParam(name = "id", value = "用户ID", required = true, dataType = "Long")
    @RequestMapping(value="/{id}", method=RequestMethod.GET)
    public User getUser(@PathVariable Long id) {
        return users.get(id);
    }

    @ApiOperation(value="更新用户详细信息", notes="根据url的id来指定更新对象，并根据传过来的user信息来更新用户详细信息")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id", value = "用户ID", required = true, dataType = "Long"),
            @ApiImplicitParam(name = "user", value = "用户详细实体user", required = true, dataType = "User")
    })
    @RequestMapping(value="/{id}", method=RequestMethod.PUT)
    public String putUser(@PathVariable Long id, @RequestBody User user) {
        User u = users.get(id);
        u.setName(user.getName());
        u.setAge(user.getAge());
        users.put(id, u);
        return "success";
    }

    @ApiOperation(value="删除用户", notes="根据url的id来指定删除对象")
    @ApiImplicitParam(name = "id", value = "用户ID", required = true, dataType = "Long")
    @RequestMapping(value="/{id}", method=RequestMethod.DELETE)
    public String deleteUser(@PathVariable Long id) {
        users.remove(id);
        return "success";
    }

}

public Docket createRestApi() {
        Predicate<RequestHandler> predicate = new Predicate<RequestHandler>() {
            @Override
            public boolean apply(RequestHandler input) {
                Class<?> declaringClass = input.declaringClass();
                if (declaringClass == BasicErrorController.class)// 排除
                    return false;
                if(declaringClass.isAnnotationPresent(RestController.class)) // 被注解的类
                    return true;
                if(input.isAnnotatedWith(ResponseBody.class)) // 被注解的方法
                    return true;
                return false;
            }
        };

public void product() throws IOException, TimeoutException {
        // 创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        //设置RabbitMQ地址
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setUsername("guest");
        factory.setPassword("guest");
        //创建一个新的连接
        Connection connection = factory.newConnection();
        //创建一个频道
        Channel channel = connection.createChannel();
        //声明一个队列 -- 在RabbitMQ中，队列声明是幂等性的（一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同），也就是说，如果不存在，就创建，如果存在，不会对已经存在的队列产生任何影响。
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        String message = "Hello World!";
        //发送消息到队列中
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
        System.out.println("P [x] Sent '" + message + "'");
        //关闭频道和连接
        channel.close();
        connection.close();
    }


    public void consumer() throws IOException, TimeoutException {
        // 创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        //设置RabbitMQ地址
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setUsername("guest");
        factory.setPassword("guest");
        //创建一个新的连接
        Connection connection = factory.newConnection();
        //创建一个频道
        Channel channel = connection.createChannel();
        //声明要关注的队列 -- 在RabbitMQ中，队列声明是幂等性的（一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同），也就是说，如果不存在，就创建，如果存在，不会对已经存在的队列产生任何影响。
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        System.out.println("C [*] Waiting for messages. To exit press CTRL+C");
        //DefaultConsumer类实现了Consumer接口，通过传入一个频道，告诉服务器我们需要那个频道的消息，如果频道中有消息，就会执行回调函数handleDelivery
        Consumer consumer = new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                String message = new String(body, "UTF-8");
                System.out.println("C [x] Received '" + message + "'");
            }
        };
        //自动回复队列应答 -- RabbitMQ中的消息确认机制
        channel.basicConsume(QUEUE_NAME, true, consumer);
    }

@Component
public class Product {
    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send() {
        String context = "hello " + new Date();
        System.out.println("生产者发送信息 : " + context);

        new Queue("hello");
        this.rabbitTemplate.convertAndSend("hello", context);
    }
}

@Component
@RabbitListener(queues = "hello")
public class Consumer {
    @RabbitHandler
    public void process(String hello) {
        System.out.println("消费者接受信息 : " + hello);
    }
}

@RunWith(SpringRunner.class)
@SpringBootTest
public class JoylauSpringBootRabbitmqApplicationTests {

	@Autowired
	private Product product;

	@Test
	public void test() throws Exception {
		product.send();
	}

}

@RabbitHandler
@RabbitListener(
        bindings = @QueueBinding(
                value = @Queue(value = "${spring.application.name}"),
                exchange = @Exchange(value = "${spring.rabbitmq.template.exchange}"),
                key = "${spring.rabbitmq.template.routing-key}")
)
public void listenerTrafficMessage(Message message){
    System.out.println(message.getClass().getName());
}

@RabbitHandler
@RabbitListener(
        bindings = @QueueBinding(
                value = @Queue(value = "${spring.application.name}"),
                exchange = @Exchange(value = "${spring.rabbitmq.template.exchange}"),
                key = "${spring.rabbitmq.template.routing-key}")
)
public void listenerTrafficMessage(Message message, Channel channel){

    System.out.println(message.getClass().getName());

    try {
        channel.basicNack(message.getMessageProperties().getDeliveryTag(),false,true);
    } catch (IOException e) {
        e.printStackTrace();
    }

}

// 告诉服务器收到这条消息 已经被我消费了 可以在队列删掉 这样以后就不会再发了
// 否则消息服务器以为这条消息没处理掉 后续还会在发，true确认所有消费者获得的消息
channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);

//最后一个参数是：是否重回队列
channel.basicNack(message.getMessageProperties().getDeliveryTag(), false,false);
//拒绝消息
//channel.basicReject(message.getMessageProperties().getDeliveryTag(), true);
//消息被丢失
//channel.basicReject(message.getMessageProperties().getDeliveryTag(), false);
//消息被重新发送
//channel.basicReject(message.getMessageProperties().getDeliveryTag(), true);
//多条消息被重新发送
//channel.basicNack(message.getMessageProperties().getDeliveryTag(), true, true);