笑松小站

RocketMQ提供的顺序消费消息实现是使用的FIFO 先进先出算法 Producer消息发送 public class Producer { public static void main(String[] args) throws UnsupportedEncodingException { try { MQProd... 阅读全文...

发布与模式实现。广播就是向一个主题的所有订阅者发送同一条消息。 在发送消息的时候和普通的消息并与不同之处，只是在消费端做一些配置即可。 Consumer消息消费public class BroadcastConsumer { public static void main(String[] args) throws MQClientException { Defau... 阅读全文...

有以下3种方式发送RocketMQ消息 可靠同步发送 reliable synchronous 可靠异步发送 reliable asynchronous 单向发送 one-way transmission 可靠同步发送 主要运用在比较重要一点消息传递/通知等业务 public class SyncProducer { public static void main(S... 阅读全文...

以下采用的是apache rocketmq 4.2.0版本 相关文档如下 了解架构设计： /2020/09/23/rocketmq-framework-des/ 快速体验： http://blog.seoui.com/2018/07/24/rocketmqinstall/ rocketmq简单消息发送： http://blog.seoui.com/2018/07/24/rocketmq... 阅读全文...

操作系统：centos7gitlab： gitlab-ee 如果是其他环境 安装过程类似 安装必要依赖 sudo yum install -y curl policycoreutils-python openssh-serversudo systemctl enable sshdsudo systemctl start sshdsudo firewall-cmd --permanent --... 阅读全文...

nexus3比以前的版本相比 多支持了管理不同的格式 比如Docker npm NuGet maven …等 下载编译好的二进制安装 wget https://sonatype-download.global.ssl.fastly.net/repository/repositoryManager/3/nexus-3.12.1-01-unix.tar.gz tar -zxf nexus-... 阅读全文...

Jenkins是基于JVM开发的，所以安装之前需要先确保装好JVM的运行环境JRE 这里采用TOMCAT的部署方式安装。 下载WAR wget http://mirrors.jenkins.io/war-stable/2.121.1/jenkins.war 然后复制到tomcat的webapps目录中 执行bin/startup.sh启动 ，bin/shutdown.sh 关闭。 首次... 阅读全文...

有时候图片被base64之后需要计算图片大小，因为被编码后全是字符，计算文件大小可以反序列化成文件之后再获取大小，但是会比较麻烦。简单介绍一种利用base64编码原理计算大小的方法。 编码原理要求把3个8位字节（3*8=24）转化为4个6位的字节（4*6=24），之后在6位的前面补两个0，形成8位一个字节的形式。 如果剩下的字符不足3个字节，用0填充，输出字符使用’=’，因此编码后输出的文本... 阅读全文...

有时候想调试线上的程序 可以启用远程调试功能 在本地调试远程代码。 远程JVM启用调试模式 /usr/local/jdk/bin/java -server -Xms256m -Xmx256m -XX:PermSize=64m -XX:MaxPermSize=128m -Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=n,addres... 阅读全文...

redis从2.6版本开始内置支持Lua解释器，解释器提供了3个函数来处理redis的命令redis.call() redis.pcall()和 redis.log,同时redis 也保证脚本会以原子性的方式执行。这是一个很重要的因素。 本文涉及到的命令有 EVAL EVALSHA SCRIPT LOAD SCRIPT FLUSH SCRIPT EXISTS SCRIPT KILL red... 阅读全文...