logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

netty使用redis发布订阅实现消息推送

操作 session 服务,并设置 用户到redis。定义session接口相关。使用 netty 容器。

#redis
java agent 拦截方法耗时

打包后,在项目上加上启动参数。

#java
docker-运维-共享宿主机的jdk

docker-运维-共享宿主机的jdk准备mkdir dc-jdkcd dc-jdk创建dockerfile在 dc-jdk中创建 Dockerfile 文件:FROM ubuntu:latestENV LANG C.UTF-8# 指定容器内jdk所在目录ENV JAVA_HOME /opt/softinstall/jdk1.8.0_11ENV CLASSPATH $JAVA...

#docker
rabbitmq 手动 ack(一)

rabbitmq 手动 ackrabbitmq 手动 ack@RabbitListener(bindings = @QueueBinding(exchange = @Exchange(value = "ex.retry.manual"),value = @Queue(value = "q.retry.manual", durable = "true"),key = "manual"), ackMo

#rabbitmq
elasticsearch-文档API操作

elasticsearch-文档API操作基于 7.12.x新增POST /book/_doc/1{"name":"从入门到精通linux","price": 100,"category":"tech"}# response{"_index": "book","_type": "_doc","_id": "1","_version": 1,"result": "created","_shards"

#elasticsearch
netty-http分块(chunked)传输技术

netty-http分块(chunked)传输技术chunked分块技术服务端将响应内容 body 体分成若干个 chunk 块来分别传输的,表现为一边计算一边传输一般在传输图片应用较为广泛表现在http响应头部增加:Transfer-Encoding: chunked格式------------------| 1-chunk|--------------...

拓扑排序实现(伪代码)

拓扑排序void TopologicalSort(Graph G){InitStack(S);for(i = 0;i < G.vexnum; i++){if(indegrdd[i]==0)Push(S, i);}int count =0;while(!Empty(S)){Pop(S,i);print[count++] = i;for(p =

ribbon负载均衡策略

ribbon负载均衡策略Greenwich.SR1版本类中文描述RandomRule随机策略随机选择serverRoundRobinRule轮询策略按顺序循环选择serverRetryRule重试策略在配置时间内选择server不成功,则一直尝试选择一个可用的serverBestAvailableRule最低并发策略逐个考察server,...

rabbitmq 多实例消费者,只允许一个实例消费者消费

一般的,在rabbitmq中,如果采用 direct 类型的exchange, 相同队列的多个消费者,消费时通过 轮询的方式,消息一次发送给A,下一条消息就发送给B, 再来一条消息就发送给 A。但是现在的场景就是即使有多个消费者实例,我只想让一个消费者消费,其他消费者作为备选,类型的队列,即在创建队列的时候,增加额外参数。创建好队列之后 ,就可以看见 队列上有一个。标签的就说明是正在消费的客户端。

#rabbitmq
flink- Could not acquire the minimum required resources

发现并不能和 flink-jobmanager 进行通信。Available Task Slots都显示始终是0。属性,将其调大,结果还是没用。查看 k8s ,发现少了。重启 flink, 解决。

#flink
    共 142 条
  • 1
  • 2
  • 3
  • 15
  • 请选择