洛基亚 黑色苹果 金色洛基亚 黑色苹果 金色洛基亚 黑色 ...
分类:
编程语言 时间:
2019-04-13 20:25:34
阅读次数:
154
集成tomcat就是随项目启动而启动tomcat,最简单的方法就是监听器监听容器创建之后以Broker的方式启动ActiveMQ。 1.web项目中Broker启动的方式进行集成 在这里采用Listener监听ServletContext创建和销毁进行Broker的启动和销毁。 0.需要的jar包: ...
分类:
编程语言 时间:
2019-04-13 01:20:40
阅读次数:
250
Queue队列的消息一般是按照顺序各个队列依次获取消息,每次获取一个。所以假设有两个队列queue1,queue2,发送的消息为1、2、3、4、5。则默认情况下queue1获取到的消息为1、3、5,queue2获取到的消息为2、4. 1.Exclusive Consume 用于队列消息 独有消费者: ...
分类:
其他好文 时间:
2019-04-12 23:07:26
阅读次数:
150
初识 A container object which may or may not contain a non null value. 笔者理解,Optional是一个容器类。将Object放到Optional中,从而可以使用容器的一些特性,比如链式编程(Stream)等。 具体应用起来,可以分为 ...
分类:
编程语言 时间:
2019-04-12 19:27:57
阅读次数:
210
在做kafka测试的时候,使用命令bin/kafka-console-consumer.sh --zookeeper 192.168.0.140:2181,192.168.0.141:2181 --topic test --from-beginning启动消费者,发现一只报错consumer zoo ...
分类:
其他好文 时间:
2019-04-12 00:57:55
阅读次数:
305
原文:RabbitMQ(四):RPC的实现一、RPC RPC(Remote Procedure Call)—远程过程调用,它是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。有很多方式可以实现,譬如UNIX RPC、REST API、WCF和SOAP。这些传统的RPC实现方法... ...
分类:
其他好文 时间:
2019-04-12 00:41:48
阅读次数:
139
Return: Map[TopicPartition, Long] Code: val props = new Properties() props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaPara("bootstrap.servers") ...
分类:
其他好文 时间:
2019-04-09 18:55:52
阅读次数:
180
一 库操作 数据库命名规则 可以由数字,字母,下划线,@, #, $ 区分大小写 唯一性 不能使用关键字如 create select 不能单独使用数字 最长128位 # 这些是对上次的补充. 二 表操作 1. MySQL的基础数据类型 简单介绍一下: 在这里介绍一下枚举个集合类型的用法 2.MyS ...
分类:
数据库 时间:
2019-04-08 21:32:33
阅读次数:
219
//1.数据库连接Connection //2.编译sql //3.结果集 //注册驱动 Class.forName("com.mysql.cj.jdbc.Driver"); //8.0 mysql.cj.jdbc //获取连接 String url = "jdbc:mysql://localhos ...
分类:
数据库 时间:
2019-04-07 09:39:27
阅读次数:
210
JDK1.8;(仅列举常见的) 一: Iterable接口:三个方法; Iterator<T> iterator(); default void forEach(Consumer<? super T> action) { Objects.requireNonNull(action); for (T ...
分类:
编程语言 时间:
2019-04-06 18:58:38
阅读次数:
117