RocketMQ部署 Linux方式和Docker方式

news2025/1/23 12:00:41

一、Linux部署

准备一台Linux机器，部署单master rocketmq节点

系统ip角色模式
CENTOS10.4.7.126Nameserver,brokerMaster

1. 配置JDK

rocketmq运行需要依赖jdk，安装步骤略。

2. 下载和配置

  1. 从官网下载安装包 https://rocketmq.apache.org/zh/download/ ，并上传到CENTOS系统中，并进行解压
cd /data
# 解压
unzip rocketmq-all-5.1.3-bin-release.zip
# 创建目录软链接
ln -s rocketmq-all-5.1.3-bin-release rocketmq
# 创建目录
#  消息存储及位点目录
 mkdir -p /data/rocketmq/store
 mkdir -p /data/rocketmq/store/commitlog
 mkdir -p /data/rocketmq/store/consumequeue
 mkdir -p /data/rocketmq/store/index
#  创建日志目录
 mkdir -p /data/rocketmq/logs
# 进入配置文件目录并替换日志配置文件中的日志目录的位置
cd /data/rocketmq/conf && sed -i 's#${user.home}#/data/rocketmq#g' *.xml

修改rocketmq启动所需配置文件

# 进入rocketmq自带的配置文件目录
[root@mq-126 conf]# cd /data/rocketmq/conf/
[root@mq-126 conf]# ls
# 2master 2slave 异步消息同步配置目录
2m-2s-async
# 2master 2slave 同步消息同步配置目录
2m-2s-sync
# 2master no slave 配置目录
2m-noslave
# 单点配置目录
broker.conf
container
controller
dledger
plain_acl.yml
# 日志配置文件
rmq.broker.logback.xml
rmq.client.logback.xml
rmq.controller.logback.xml
rmq.namesrv.logback.xml
rmq-proxy.json
rmq.proxy.logback.xml
rmq.tools.logback.xml
tools.yml
[root@mq-126 conf]# vi broker.conf

将下面的配置赋值到broker.conf中

#所属集群名字
brokerClusterName=rocketmq-cluster
#broker 名字，注意此处不同的配置文件填写的不一样
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer 地址，分号分割
namesrvAddr=127.0.0.1:9876
#在发送消息时，自动创建服务器不存在的 topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建 Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=10911
#删除文件时间点，默认凌晨 4 点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog 每个文件的大小默认 1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue 每个文件默认存 30W 条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=/data/rocketmq/store
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/data/rocketmq/store/consumequeue #消息索引存储路径
storePathIndex=/data/rocketmq/store/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/store/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq/store/abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制 Master
#- SYNC_MASTER 同步双写 Master
#- SLAVE
brokerRole=ASYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128

修改启动脚本的jvm参数，找到对应行进行修改，原配置设置的内存太大，我的虚拟机是1g内存的，会无法正常启动，需要改小。

  • vim /data/rocketmq/bin/runbroker.sh

    JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m"

  • vim /data/rocketmq/bin/runserver.sh

    JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m"

3. 启动

  1. 启动nameserver

    [root@mq-126 rocketmq]# nohup sh /data/rocketmq/bin/mqnamesrv &

[root@mq-126 rocketmq]# jps
2617 NamesrvStartup
2654 Jps
[root@mq-126 rocketmq]# netstat -ano | grep 9876
tcp6       0      0 :::9876                 :::*                    LISTEN      off (0.00/0/0)
tcp6       0      0 10.4.7.126:9876         10.4.7.126:53946        ESTABLISHED off (0.00/0/0)
tcp6       0      0 10.4.7.126:9876         10.4.7.125:42368        ESTABLISHED off (0.00/0/0)
tcp6       0      0 10.4.7.126:53946        10.4.7.126:9876         ESTABLISHED off (0.00/0/0)

  2. 启动broker

    [root@mq-126 bin]# nohup sh /data/rocketmq/bin/mqbroker -c /data/rocketmq/conf/broker.conf &
[2] 2829
[root@mq-126 bin]# jps
2796 NamesrvStartup
2861 BrokerStartup
2893 Jps

  3. 启动dashboard

    启动dashboard最快的方式是通过docker进行启动。

    [root@mq-126 bin]# systemctl start docker
[root@mq-126 bin]# docker run -d --name rocketmq-dashboard -e "JAVA_OPTS=-Drocketmq.namesrv.addr=10.4.7.126:9876" -p 8080:8080 -t apacherocketmq/rocketmq-dashboard:latest
d55cb8b7ff0e9d19964c2019eaf4bba8301cfc2cf1b8a3eb01bff09df134f90e

    然后就可以访问dashboard了

    如果没有docker环境 在官网下下载源码包，使用maven编译后进行启动

    https://rocketmq.apache.org/zh/download/

4. 发送和消费测试代码

Producer

package cn.shutdown.mq;

import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.exception.RemotingException;

/**
 * 消息生产者
 * @author Domino.J
 * @date 2023/8/11
 */
public class Producer {

    public static final String NAMESRV_ADDR = "10.4.7.126:9876";
    public static void main(String[] args)
            throws MQClientException, MQBrokerException, RemotingException, InterruptedException {
        DefaultMQProducer producer = new DefaultMQProducer("test_quick_producer_name");
        producer.setNamesrvAddr(NAMESRV_ADDR);
        producer.start();

        for (int i = 0; i < 1000; i++) {
            Message message = new Message("test_quick_topic",//主题
                    "TagA", //标签
                    "KeyA" + i, //用户自定义的key，唯一的标识
                    ("Hello RocketMQ" + i).getBytes());//消息内容
            //发送消息
            SendResult sr = producer.send(message);
            System.out.println("消息发送结果：" + sr);
            Thread.sleep(1000);
        }
        producer.shutdown();
    }
}

Consumer

package cn.shutdown.mq;

import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.remoting.common.RemotingHelper;

import java.util.List;

/**
 * 消息消费者
 * @author Domino.J
 * @date 2023/8/11
 */
public class Consumer {

    public static final String NAMESRV_ADDR = "10.4.7.126:9876";

    public static void main(String[] args) throws MQClientException {

        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("test_quick_consumer_name");
        consumer.setNamesrvAddr(NAMESRV_ADDR);
        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);
        consumer.subscribe("test_quick_topic", "*");
        consumer.registerMessageListener(new MessageListenerConcurrently() {
        	@Override
        	public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
                MessageExt me = msgs.get(0);
                try {
                    String topic = me.getTopic();
                    String tags = me.getTags();
                    String keys = me.getKeys();
                    String msgBody = new String(me.getBody(), RemotingHelper.DEFAULT_CHARSET);
                    System.err.println("topic: " + topic + ",tags: " + tags + ", keys: " + keys + ",body: " + msgBody);
                } catch (Exception e) {
                    e.printStackTrace();
                    return ConsumeConcurrentlyStatus.RECONSUME_LATER;
                }
                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
            }
        });

        consumer.start();
        System.err.println("consumer start...");

    }
}

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>cn.shutdown</groupId>
    <artifactId>rocketmq-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>rocketmq-demo</name>
    <description>rocketmq-demo</description>
    <properties>
        <java.version>1.8</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <spring-boot.version>2.6.13</spring-boot.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-client-java</artifactId>
            <version>5.0.3</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-client</artifactId>
            <version>5.1.3</version>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.8.1</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                    <encoding>UTF-8</encoding>
                </configuration>
            </plugin>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>${spring-boot.version}</version>
                <configuration>
                    <mainClass>cn.shutdown.mq.RocketmqDemoApplication</mainClass>
                    <skip>true</skip>
                </configuration>
                <executions>
                    <execution>
                        <id>repackage</id>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>
</project>

运行结果

二、Docker Compose部署

1. 拉取镜像

拉取 rocketmq镜像

docker pull apache/rocketmq:5.1.3

拉取 rocketmq dashboard镜像

docker pull apacherocketmq/rocketmq-dashboard:latest

2. 创建挂载目录，拷贝挂载文件

  1. 创建Nameserver需要的挂载目录并拷贝挂载文件

    # 日志目录
mkdir /data/opt/rocketmq/nameserver/logs -p
# 脚本目录
mkdir /data/opt/rocketmq/nameserver/bin -p

    设置权限：如果不设置会导致NameServer容器内部无法写日志文件

    # 777 文件所属者、文件所属组和其他人有读取 & 写入 & 执行全部权限。rwxrwxrwx
chmod 777 -R /data/opt/rocketmq/nameserver/*

    正如使用Linux部署一样，需要修改JAVA_OPT配置，这里需要从rocketmq容器中复制出一份运行文件，修改后再挂载到新启动的容器上。另外，NameServer启动脚本中有一个自动计算最大堆内存和新生代内存的函数会导致在不同硬件环境下设置最大堆内存和新生代内存环境变量不被应用，，这里先提前copy一份容器内部启动脚本做挂载，如果想自定义内存可以自己调整。

    启动临时rocketmq容器

    docker run -d \
--privileged=true \
--name rmqnamesrv \
apache/rocketmq:5.1.3 sh mqnamesrv

    复制容器内的文件到挂载目录中

    [root@mq-126 bin]# docker cp rmqnamesrv:/home/rocketmq/rocketmq-5.1.3/bin/ /data/opt/rocketmq/nameserver/
[root@mq-126 bin]# ls
cachedog.sh           mqbroker.numanode0  os.sh
cleancache.sh         mqbroker.numanode1  play.cmd
cleancache.v1.sh      mqbroker.numanode2  play.sh
controller            mqbroker.numanode3  README.md
dledger               mqcontroller        runbroker.cmd
docker-entrypoint.sh  mqcontroller.cmd    runbroker.sh
export.sh             mqnamesrv           runserver.cmd
mqadmin               mqnamesrv.cmd       runserver.sh
mqadmin.cmd           mqproxy             setcache.sh
mqbroker              mqproxy.cmd         startfsrv.sh
mqbroker.cmd          mqshutdown          tools.cmd
mqbrokercontainer     mqshutdown.cmd      tools.sh

    修改 runserver.sh，把 calculate_heap_sizes 这句注释掉，

    # 注释掉以下这句
# calculate_heap_sizes

# Dynamically calculate parameters, for reference.

    然后停止并删除容器

    docker stop rmqnamesrv && docker rm rmqnamesrv

  2. 创建Broker需要挂载的文件夹和文件

    # 创建需要的挂载目录
mkdir /data/opt/rocketmq/broker/logs -p 
mkdir /data/opt/rocketmq/broker/data -p 
mkdir /data/opt/rocketmq/broker/conf -p 
mkdir /data/opt/rocketmq/broker/bin -p 
mkdir /data/opt/rocketmq/broker/store -p

    给目录赋权限

    # 777 文件所属者、文件所属组和其他人有读取 & 写入 & 执行全部权限。rwxrwxrwx
chmod 777 -R /data/opt/rocketmq/broker/*

    启动临时容器

    docker run -d \
--name rmqbroker \
--privileged=true \
apache/rocketmq:5.1.3 \
sh mqbroker

    拷贝运行文件

    [root@mq-126 bin]# docker cp rmqbroker:/home/rocketmq/rocketmq-5.1.3/bin/ /data/opt/rocketmq/broker/
Successfully copied 110kB to /data/opt/rocketmq/broker/
[root@mq-126 bin]# ls
cachedog.sh           mqbroker.numanode0  os.sh
cleancache.sh         mqbroker.numanode1  play.cmd
cleancache.v1.sh      mqbroker.numanode2  play.sh
controller            mqbroker.numanode3  README.md
dledger               mqcontroller        runbroker.cmd
docker-entrypoint.sh  mqcontroller.cmd    runbroker.sh
export.sh             mqnamesrv           runserver.cmd
mqadmin               mqnamesrv.cmd       runserver.sh
mqadmin.cmd           mqproxy             setcache.sh
mqbroker              mqproxy.cmd         startfsrv.sh
mqbroker.cmd          mqshutdown          tools.cmd
mqbrokercontainer     mqshutdown.cmd      tools.sh

    修改 runbroker.sh，把 calculate_heap_sizes 这句注释掉，

    # 注释掉以下这句
# calculate_heap_sizes

# Dynamically calculate parameters, for reference.

    拷贝配置文件

    [root@mq-126 conf]# docker cp rmqbroker:/home/rocketmq/rocketmq-5.1.3/conf/ /data/opt/rocketmq/broker/
Successfully copied 145kB to /data/opt/rocketmq/broker/
[root@mq-126 conf]# ls
2m-2s-async  dledger                     rmq-proxy.json
2m-2s-sync   plain_acl.yml               rmq.proxy.logback.xml
2m-noslave   rmq.broker.logback.xml      rmq.tools.logback.xml
broker.conf  rmq.client.logback.xml      tools.yml
container    rmq.controller.logback.xml
controller   rmq.namesrv.logback.xml

    修改 broker.conf

    # 集群名称
brokerClusterName = DefaultCluster
# 节点名称
brokerName = broker-a
# broker id节点ID， 0 表示 master, 其他的正整数表示 slave，不能小于0 
brokerId = 0
# Broker服务地址	String	内部使用填内网ip，如果是需要给外部使用填公网ip
brokerIP1 = 10.4.7.125
# Broker角色
brokerRole = ASYNC_MASTER
# 刷盘方式
flushDiskType = ASYNC_FLUSH
# 在每天的什么时间删除已经超过文件保留时间的 commit log，默认值04
deleteWhen = 04
# 以小时计算的文件保留时间 默认值72小时
fileReservedTime = 72
# 是否允许Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
# 是否允许Broker自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true

    停止并删除临时的broker容器

    docker stop rmqbroker && docker rm rmqbroker

3. 准备Docker Compose 文件

在/data/opt/rocketmq目录创建docker-compose.yml文件

version: '3.8'
services:
  rmqnamesrv:
    image: apache/rocketmq:5.1.3
    container_name: rmqnamesrv
    ports:
      - 9876:9876
    restart: always
    privileged: true
    volumes:
      - /data/opt/rocketmq/nameserver/logs:/home/rocketmq/logs
      - /data/opt/rocketmq/nameserver/bin/runserver.sh:/home/rocketmq/rocketmq-5.1.3/bin/runserver.sh
    environment:
      - MAX_HEAP_SIZE=256M
      - HEAP_NEWSIZE=128M
    command: ["sh","mqnamesrv"]
  broker:
    image: apache/rocketmq:5.1.3
    container_name: rmqbroker
    ports:
      - 10909:10909
      - 10911:10911
      - 8081:8081
    restart: always
    privileged: true
    volumes:
      - /data/opt/rocketmq/broker/logs:/home/rocketmq/logs
      - /data/opt/rocketmq/broker/store:/home/rocketmq/store
      - /data/opt/rocketmq/broker/conf/broker.conf:/home/rocketmq/broker.conf
      - /data/opt/rocketmq/broker/bin/runbroker.sh:/home/rocketmq/rocketmq-5.1.3/bin/runbroker.sh
    depends_on:
      - 'rmqnamesrv'
    environment:
      - NAMESRV_ADDR=rmqnamesrv:9876
      - MAX_HEAP_SIZE=512M
      - HEAP_NEWSIZE=256M
    command: ["sh","mqbroker","-c","/home/rocketmq/broker.conf","--enable-proxy"]
  rmqdashboard:
    image: apacherocketmq/rocketmq-dashboard:latest
    container_name: rocketmq-dashboard-latest
    ports:
      - 8080:8080
    restart: always
    privileged: true
    depends_on:
      - 'rmqnamesrv'
    environment:
      - JAVA_OPTS= -Xmx256M -Xms256M -Xmn128M -Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false

使用docker compose 命令启动

[root@mq_125 rocketmq]# vi docker-compose.yml
[root@mq_125 rocketmq]# docker compose up -d
[+] Building 0.0s (0/0)
[+] Running 3/3
 ✔ Container rmqnamesrv                 Started              0.7s
 ✔ Container rocketmq-dashboard-latest  Started              2.6s
 ✔ Container rmqbroker                  Started

4. 发送和消费消息测试

测试代码与linux部署相同

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/883296.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

三.net core 自动化发布到docker （创建一个dotnet工程发布）

三.net core 自动化发布到docker （创建一个dotnet工程发布）

创建Jenkins-create a job 输入名称&#xff08;建议不要带“”这类的字符&#xff09;&#xff0c;选择自由风格的类型&#xff08;红框标注的&#xff09;&#xff0c;点击确定 用于测试,下面选项基本没有选择-配置代码地址 选择执行shell #!/bin/bash # 获取短版本号 GITHA…
阅读更多...
会一点stm32，只后是做嵌入式Linux还是转JAVA？

会一点stm32，只后是做嵌入式Linux还是转JAVA？

选择嵌入式Linux还是转向JAVA&#xff0c;取决于你的兴趣、职业规划和就业市场的需求。以下是一些考虑因素&#xff1a;兴趣和擅长&#xff1a;首先&#xff0c;你应该考虑自己对嵌入式Linux和JAVA的兴趣和擅长程度。如果你对嵌入式系统、硬件交互和底层编程更感兴趣&#xff0…
阅读更多...
echart 3d立体颜色渐变柱状图

echart 3d立体颜色渐变柱状图

如果可以实现记得点赞分享&#xff0c;谢谢老铁&#xff5e; 1.需求描述 根据业务需求将不同的法律法规&#xff0c;展示不同的3d立体渐变柱状图。 2.先看下效果图 3. 确定三面的颜色&#xff0c;这里我是自定义的颜色 // 右面生成颜色const rightColorArr ref(["#79D…
阅读更多...
【图像融合】融合算法综述（持续更新）

【图像融合】融合算法综述（持续更新）

按时间顺序&#xff0c;综述近5年的融合算法。重点分析了最近两年的work&#xff0c;欢迎留言探讨 文章目录 前言1.SSR-Laplacian Image Fusion&#xff08;2017&#xff09;2、FusionGAN&#xff08;2019&#xff09;3、MBNet&#xff08;2020&#xff09;4、DIDFuse&#xff…
阅读更多...
【闪击Linux系列P10】操作系统管理的算珠——进程の详解

【闪击Linux系列P10】操作系统管理的算珠——进程の详解

​ 前言 大家好吖&#xff0c;欢迎来到 YY 滴 Linux系列 &#xff0c;热烈欢迎&#xff01; 本章主要内容面向接触过Linux的老铁&#xff0c;从操作系统层面向大家介绍进程&#xff1a; 主要内容含&#xff1a; 欢迎订阅 YY滴Linux专栏&#xff01;更多干货持续更新&#xff0…
阅读更多...
AIGC绘画：基于Stable Diffusion进行AI绘图

AIGC绘画：基于Stable Diffusion进行AI绘图

文章目录 AIGC深度学习模型绘画系统stable diffusion简介stable diffusion应用现状在线网站云端部署本地部署Stable Diffusion AIGC深度学习模型绘画系统 stable diffusion简介 Stable Diffusion是2022年发布的深度学习文本到图像生成模型&#xff0c;它主要用于根据文本的描述…
阅读更多...
MySQL — 索引

MySQL — 索引

文章目录 索引索引结构 — B树与B树B树B树 聚簇索引与非聚簇索引聚簇索引非聚簇索引优缺点 覆盖索引与回表联合索引索引覆盖最左前缀匹配 索引 索引是对数据库表中一列或多列的值进行排序的一种结构。MySQL索引的建立对于MySQL的高效运行是很重要的&#xff0c;索引可以大大提…
阅读更多...
图像去雨-雨线清除-图像处理-（计算机作业附代码）

图像去雨-雨线清除-图像处理-（计算机作业附代码）

背景 多年来&#xff0c;图像去雨已经被广泛研究&#xff0c;使用传统方法和基于学习的方法。然而&#xff0c;传统方法如高斯混合模型和字典学习方法耗时&#xff0c;并且无法很好地处理受到严重雨滴影响的图像块。 算法 通过考虑雨滴条状特性和角度分布&#xff0c;这个问…
阅读更多...
2023+HuggingGPT: Solving AI Tasks with ChatGPT and itsFriends in Hugging Face

2023+HuggingGPT: Solving AI Tasks with ChatGPT and itsFriends in Hugging Face

摘要&#xff1a; 语言是llm(例如ChatGPT)连接众多AI模型(例如hugs Face)的接口&#xff0c;用于解决复杂的AI任务。在这个概念中&#xff0c;llms作为一个控制器&#xff0c;管理和组织专家模型的合作。LLM首先根据用户请求规划任务列表&#xff0c;然后为每个任务分配专家模…
阅读更多...
3D- vista:预训练的3D视觉和文本对齐Transformer

3D- vista:预训练的3D视觉和文本对齐Transformer

论文&#xff1a;https://arxiv.org/abs/2308.04352 代码: GitHub - 3d-vista/3D-VisTA: Official implementation of ICCV 2023 paper "3D-VisTA: Pre-trained Transformer for 3D Vision and Text Alignment" 摘要 三维视觉语言基础(3D- vl)是一个新兴领域&…
阅读更多...
JDBC封装与设计模式

JDBC封装与设计模式

什么是 DAO &#xff1f; Data Access Object(数据存取对象) 位于业务逻辑和持久化数据之间实现对持久化数据的访问 DAO起着转换器的作用&#xff0c;将数据在实体类和数据库记录之间进行转换。 ----------------------------------------------------- DAO模式的组成部分 …
阅读更多...
【动画】p60动画蓝图、播放蒙太奇、打包

【动画】p60动画蓝图、播放蒙太奇、打包

p60动画蓝图、播放蒙太奇、打包 p60动画蓝图、播放蒙太奇、打包添加动画动画蓝图使模型使用动画蓝图奔跑跳舞蒙太奇 移动打断蒙太奇打包退出游戏 p60动画蓝图、播放蒙太奇、打包 添加动画 右键内容浏览器-》动画-》混合空间1D-》选择新的角色的骨骼 如下图在资产详情修改参数…
阅读更多...
【TypeScript】基础类型

【TypeScript】基础类型

安装 Node.js 环境 https://nodejs.org/en 终端中可以查到版本号即安装成功。 然后&#xff0c;终端执行npm i typescript -g安装 TypeScript 。 查到版本号即安装成功。 字符串类型 let str:string "Hello"; console.log(str);终端中先执行tsc --init&#xf…
阅读更多...
机器学习：特征工程之特征预处理

机器学习：特征工程之特征预处理

目录 特征预处理 1、简述 2、内容 3、归一化 3.1、鲁棒性 3.2、存在的问题 4、标准化 ⭐所属专栏&#xff1a;人工智能 文中提到的代码如有需要可以私信我发给你&#x1f60a; 特征预处理 1、简述 什么是特征预处理&#xff1a;scikit-learn的解释&#xff1a; provide…
阅读更多...
预训练GNN：GPT-GNN Generative Pre-Training of Graph Neural Networks

预训练GNN：GPT-GNN Generative Pre-Training of Graph Neural Networks

一.文章概述 本文提出了一种自监督属性图生成任务来预训练GNN&#xff0c;使得其能捕图的结构和语义属性。作者将图的生成分为两个部分&#xff1a;属性生成和边生成&#xff0c;即给定观测到的边&#xff0c;生成节点属性&#xff1b;给定观测到的边和生成的节点属性&#xf…
阅读更多...
【第三阶段】kotlin中使用带let的安全调用

【第三阶段】kotlin中使用带let的安全调用

let常常和&#xff1f;.配合使用&#xff0c;如果前面的对象为null,let不执行&#xff0c;能够执行到let里面 对象一定不为null 1.不为null fun main() {var name:String?"kotlin" //name是一个可空类型&#xff0c;发出广播&#xff0c;调用的地方必须补救措施var…
阅读更多...
WSL2 Ubuntu子系统安装cuda+cudnn+torch

WSL2 Ubuntu子系统安装cuda+cudnn+torch

文章目录 前言一、安装cudncudnn安装pytorch 前言 确保Windows系统版本高于windows10 21H2或Windows11&#xff0c;然后在Windows中将显卡驱动升级到最新即可&#xff0c;WSL2已支持对显卡的直接调用。 一、安装cudncudnn 配置cuda环境&#xff0c;WSL下的Ubuntu子系统的cu…
阅读更多...
炬芯科技低延迟高音质无线麦克风解决方案

炬芯科技低延迟高音质无线麦克风解决方案

随着互联网技术的高速发展&#xff0c;诸多新兴产业被带动起来。就近十年来看&#xff0c;内容平台以及其载体在不断演变&#xff0c;从自媒体到短视频以及直播&#xff0c;一点一滴地渗透进大众生活。而这些平台的兴起&#xff0c;亦为普罗大众提供了广阔的分享空间&#xff0…
阅读更多...
六十四卦-整体

六十四卦-整体

前言&#xff1a;整理一下学习的卦&#xff0c;从整体上更好地了解六十四卦。 目录 八纯卦 难卦 消息卦 最吉的卦 六爻皆正位的卦 六爻皆不正位的卦 爻辞中含有“利涉大川”的卦 八纯卦 乾三连&#xff0c;坤六断&#xff0c;震仰盂&#xff0c;艮覆碗&#xff0c;离…
阅读更多...
【免费分享 图书】《阿里云天池大赛赛题解析——机器学习篇》-PDF电子书-百度云...

【免费分享 图书】《阿里云天池大赛赛题解析——机器学习篇》-PDF电子书-百度云...

找这本书的资源简直要把我找吐了&#xff0c;各种网站压缩包一下下来就开始各种套路(比如要你充钱) 为了防止还有我这样的受害者&#xff0c;这就把找到的PDF给大家分享一下。 链接在文章最后 如果这篇文章能够帮到您&#xff0c;麻烦帮我点个赞&#xff0c;并关注一下我&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023