- 博客(20)
- 收藏
- 关注
RSS订阅原创 kafka管理界面 kafka-eagle
下载地址： http://download.kafka-eagle.org/：修改kafka启动命令：注：eagle是通过JMX方式拉取数据，首先需要修改kafka启动命令，开启JMX端口，集群中的每个节点都需要改！vi /home/kafka/kafka_2.11-2.0.0/bin/kafka-server-start.shif [ "x$KAFKA_HEAP_OPTS" = "x" ]; then export KAFKA_HEAP_OPTS="-server -Xms2G -X
2021-07-07 14:20:38
8261
1
原创 kafka集群安装
一.解压 tar -zxvf kafka_2.10-0.10.2.1.tgz二.修改配置文件server.properties log.dirs=/data/qc_collect/kafka/log zookeeper.connect=localhost:2181三.后台启动 ./kafka-server-start.sh -daemon ../config/server.properties四.常用命令 1.创建topic：./kafka-topics.sh --create
2021-07-07 13:20:17
198
原创 zookeeper集群搭建
Zookeeper集群安装1.解压安装包tar -zxvf zookeeper-3.3.6.tar.gz2.进入conf目录修改配置文件，将 zoo_sample.cfg 文件复制并重命名为 zoo.cfg 文件。cp zoo_sample.cfg zoo.cfg3.vim zoo.cfg，进入编辑server.A=B:C:D形式->A代表服务器编号（这个编号A需要在data目录下创建myid文件并将编号写入），B是服务器ip，C是Zookeeper服务器之间的通信端口，D是Lead
2021-07-02 15:03:56
121
原创 Elasticsearch聚合统计
Elasticsearch聚合查询语法一.范围查询，分组统计将语句转为java客户端查询语句(RestHighLevelClient)一.范围查询，分组统计将语句转为java客户端查询语句(RestHighLevelClient)SearchRequest searchRequest = new SearchRequest(indices); SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
2021-06-30 13:52:23
918
原创 Elasticsearch集群配置
Elasticsearch集群配置配置cluster.name: esnode.name: node-3path.data: /home/elasticsearch/elasticsearch-6.8.0/datapath.logs: /home/elasticsearch/elasticsearch-6.8.0/lognetwork.host: 0.0.0.0http.port: 9203#发现另外两台服务discovery.zen.ping.unicast.hosts: ["ip:93
2021-06-30 13:20:09
170
原创 springmvc
web.xml中配置springmvc核心servlet <servlet> <servlet-name>springmvc</servlet-name> <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class> <init-param> <param-name>contextConf
2020-07-26 22:43:18
76
原创 将字符串main-action-holder，转换为mainActionHolder
public class Test { public static void main(String[] args) { String str = "main-action-holder"; String name = getName(str); System.out.println(name); } static String getName(String str){ int index = str.indexOf("-");
2020-07-22 22:24:03
136
原创 长度为N的数组，随机放入值为1-50中间的任意整数，找出其中的偶数数字，并按照该数字在数组中出现次数从多到少排序输出。
问题：长度为N的数组，随机放入值为1-50中间的任意整数，找出其中的偶数数字，并按照该数字在数组中出现次数从多到少排序输出。1.生成数组static int[] createArray(int n){ int[] arr = new int[n]; for (int i = 0; i < n; i++) { int num = (int)(Math.random()*50+1); arr[i] = num;
2020-07-18 00:22:04
645
1
原创 掷骰子概率
写一个验证掷骰子概率的程序，同时投掷2颗6面骰子n次，计算其和得到各数字的概率。分析1：随机数（Random）演示掷骰子概率,将两次的和记录到map中:Map<Integer,Integer> map = new HashMap<>(); for (int i = 0; i < n; i++) { //第一次掷骰子 int num1 = (int)(Math.random()*6 + 1);
2020-07-17 23:49:07
2591
原创 rabbitMQ结合动态代理
使用动态代理实现消费端幂等性验证和消费确认（ack）动态代理要求目标对象是实现接口的目标对象，所以先写一个消费接口public interface BaseConsumer{ void consumer(Message message, Channel channel);}实现类：@Component@Slf4jpublic class MailConsumer implements BaseConsumer{ @Autowired private MailUtil ma
2020-07-17 22:02:45
397
原创 SpringBoot+RabbitMQ，发送邮件
RabbitMQ、邮箱配置# rabbitmqspring.rabbitmq.host=spring.rabbitmq.port=#spring.rabbitmq.virtual-host=spring.rabbitmq.username=spring.rabbitmq.password=# 开启confirms回调 P -> Exchangespring.rabbitmq.publisher-confirms=true# 开启returnedMessage回调 Exchange .
2020-07-16 22:29:37
854
原创 RabbitMQ初识
关于AMQP协议AMQP(高级消息队列协议)是一个网络协议，它支持符合要求的客户端应用（application）和消息中间件代理（messaging middleware broker）之间进行通信消息代理和他们所扮演的角色消息代理（message brokers）从发布者（publishers）亦称生产者（producers）那儿接收消息，并根据既定的路由规则把接收到的消息发送给处理消息的消费者（consumers）。由于AMQP是一个网络协议，所以这个过程中的发布者，消费者，消息代理 可以存在于
2020-07-12 18:03:12
147
原创 自定义RedisTemplate
redis自定义RedisTemplate1.RedisTemplate默认采用的是JDK的序列化策略，保存的key和value都是采用此策略序列化保存的。2.StringRedisTemplate默认采用的是String的序列化策略，保存的key和value都是采用此策略序列化保存的。我们可以自定义RedisTemplate指定序列化策略@Configurationpublic class RedisConfig { //编写自己的RedisTemplate @Bean
2020-06-27 20:39:16
450
1
原创 elasticsearch 安装及简单使用
elasticsearch 安装1.安装完es之后需要在安装一个【可视化界面head】插件，但在连接时会有跨域问题需要配置：http.cors.enabled: truehttp.cors.allow-origin: "*"2.使用IK分词器对于自己需要的词可以将其加入分词器词典中，ik 分词器增加自己的配置：...
2020-06-17 14:47:38
122
原创 springBoot整合shiro
springBoot整合shiro自定义Realm域Shiro 配置自定义的自定义的sessionManager自定义Realm域public class MyRealm extends AuthorizingRealm { public void setName(String name){ super.setName("customRealm"); } @Resource private UserService userService; /
2020-05-31 16:30:59
106
原创 springBoot集成JWT
springBoot搭建JWT一.登录方法二.JWT工具类三.自定义拦截器获取token并验证token四.配置拦截器一.登录方法1.登录方法可以在验证成功后保存用户信息，角色权限等 @RequestMapping("/login") public Result login(String userName,String passWord){ String jwt = ""; User user = userService.findUserByUserna
2020-05-31 15:35:41
147
转载 JSON.stringify(value, replacer, space)详解
JSON.stringify(value, replacer, space)详解 ...
2020-05-11 14:42:42
671
原创 ul列表向上循环滚动
ul列表向上循环滚动html和jshtml和js<div class=".mainNer_two_mid"> <ul> <li></li> </ul</div> function movedome(){ var liH = $(“.mainNer_two_mid>ul>li”).eq(0).height(); $(".mainNer_two_mid>ul").animate({ "marginT
2020-05-11 11:08:47
1350
转载 java常用api
转载自：https://blog.csdn.net/u013547284/article/details/71158100一、JAVA常用APIjava.lang.Math提供sin, cos, tan, exp, log, log10 等类方法，PI和E等类字段java.lang.String（StringBuilder线程不安全，StringBuffer线程安全） cha...
2019-07-19 11:11:03
179
翻译 tomcat启动中文乱码
1.tomcat的bin目录下的catalina.batset “JAVA_OPTS=%JAVA_OPTS% %JSSE_OPTS% -Dfile.encoding=UTF-8”2.conf/server.xml3.到tomcat/conf/目录下修改logging.properties 找到 java.util.logging.ConsoleHandler.encoding = utf...
2019-07-15 17:03:36
496
空空如也
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人