常用的设计模式以及操作Redis、MySQL数据库、各种MQ、数据类型转换的方法

本文涉及的产品
云数据库 Redis 版,社区版 2GB
推荐场景:
搭建游戏排行榜
云数据库 RDS MySQL Serverless,0.5-2RCU 50GB
简介: 常用的设计模式以及操作Redis、MySQL数据库、各种MQ、数据类型转换的方法


🌟 如何优雅地写出高质量的Java代码

Java作为一门高级编程语言,被广泛应用于各种应用程序开发中。写出高质量的Java代码是每一个Java开发人员的追求。本文将介绍如何优雅地写出高质量的Java代码,包括设计模式、操作Redis、MySQL数据库、各种MQ、数据类型转换等方面。

🍊 设计模式

设计模式是Java开发中的重要概念,它是一种解决常见问题的经典思想。设计模式的好处在于,它可以提升代码的可读性、可维护性和可扩展性。以下是Java开发中常用的设计模式:

🎉 单例模式

单例模式是一种只允许创建一个实例的设计模式。在Java中,可以通过以下方式来实现单例模式:

public class Singleton {
    private static Singleton instance;
    private Singleton() {}
    public static Singleton getInstance() {
        if (instance == null) {
            instance = new Singleton();
        }
        return instance;
    }
}

🎉 工厂模式

工厂模式是一种将对象的创建和使用分离的设计模式。在Java中,可以通过以下方式来实现工厂模式:

public interface Shape {
    void draw();
}
public class Rectangle implements Shape {
    @Override
    public void draw() {
        System.out.println("Drawing a rectangle");
    }
}
public class Circle implements Shape {
    @Override
    public void draw() {
        System.out.println("Drawing a circle");
    }
}
public class ShapeFactory {
    public Shape getShape(String shapeType) {
        if (shapeType == null) {
            return null;
        }
        if (shapeType.equalsIgnoreCase("rectangle")) {
            return new Rectangle();
        } else if (shapeType.equalsIgnoreCase("circle")) {
            return new Circle();
        }
        return null;
    }
}

🎉 观察者模式

观察者模式是一种用于对象间的一对多依赖关系的设计模式。在Java中,可以通过以下方式来实现观察者模式:

public interface Observer {
    void update(String message);
}
public interface Subject {
    void attach(Observer observer);
    void detach(Observer observer);
    void notifyObservers(String message);
}
public class ConcreteSubject implements Subject {
    private List<Observer> observers = new ArrayList<>();
    @Override
    public void attach(Observer observer) {
        observers.add(observer);
    }
    @Override
    public void detach(Observer observer) {
        observers.remove(observer);
    }
    @Override
    public void notifyObservers(String message) {
        for (Observer observer : observers) {
            observer.update(message);
        }
    }
}
public class ConcreteObserver implements Observer {
    private String name;
    public ConcreteObserver(String name) {
        this.name = name;
    }
    @Override
    public void update(String message) {
        System.out.println(name + " received message: " + message);
    }
}

🍊 操作Redis

Redis是一种高性能的键值存储数据库,它可以用于缓存、队列等应用场景。以下是Java中操作Redis常用的方法:

🎉 连接Redis

Jedis jedis = new Jedis("localhost", 6379);

🎉 存储数据

jedis.set("key", "value");

🎉 获取数据

String value = jedis.get("key");

🎉 删除数据

jedis.del("key");

🎉 关闭连接

jedis.close();

🍊 操作MySQL数据库

MySQL是一种常用的关系型数据库,Java操作MySQL也非常常见。以下是Java中操作MySQL常用的方法:

🎉 连接MySQL

String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "password";
Connection conn = DriverManager.getConnection(url, user, password);

🎉 插入数据

String sql = "INSERT INTO table (column1, column2) VALUES (?, ?)";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setString(1, "value1");
pstmt.setString(2, "value2");
pstmt.executeUpdate();

🎉 查询数据

String sql = "SELECT * FROM table WHERE column1=?";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setString(1, "value1");
ResultSet rs = pstmt.executeQuery();
while (rs.next()) {
    String column2 = rs.getString("column2");
}

🎉 更新数据

String sql = "UPDATE table SET column1=? WHERE column2=?";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setString(1, "value1");
pstmt.setString(2, "value2");
pstmt.executeUpdate();

🎉 删除数据

String sql = "DELETE FROM table WHERE column1=?";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setString(1, "value1");
pstmt.executeUpdate();

🎉 关闭连接

conn.close();

🍊 各种MQ

MQ(Message Queue)是一种网络通信协议,用于实现异步消息通信。以下是Java中常用的MQ:

🎉 ActiveMQ

ActiveMQ是一种流行的开源消息通信中间件,它支持多种协议,包括AMQP、STOMP、MQTT等。以下是Java中使用ActiveMQ的方法:

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("queue");
MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage("Hello, world!");
producer.send(message);
session.close();
connection.close();

🎉 RabbitMQ

RabbitMQ是一种功能齐全的开源消息通信中间件,它支持多种协议,包括AMQP。以下是Java中使用RabbitMQ的方法:

ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("localhost");
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare("queue", false, false, false, null);
String message = "Hello, world!";
channel.basicPublish("", "queue", null, message.getBytes());
channel.close();
connection.close();

🎉 Kafka

Kafka是一种高吞吐量的分布式发布订阅消息系统,它的设计目标就是处理大规模的消息数据。以下是Java中使用Kafka的方法:

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all");
props.put("retries", 0);
props.put("batch.size", 16384);
props.put("linger.ms", 1);
props.put("buffer.memory", 33554432);
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
Producer<String, String> producer = new KafkaProducer<>(props);
String topic = "topic";
String message = "Hello, world!";
producer.send(new ProducerRecord<>(topic, message));
producer.close();

🍊 数据类型转换

数据类型转换是Java开发中的常见操作,它可以将不同的数据类型之间进行转换。以下是Java中常用的数据类型转换方法:

🎉 String转int

String str = "123";
int i = Integer.parseInt(str);

🎉 int转String

int i = 123;
String str = Integer.toString(i);

🎉 String转double

String str = "3.14";
double d = Double.parseDouble(str);

🎉 double转String

double d = 3.14;
String str = Double.toString(d);

🎉 Date转String

Date date = new Date();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String str = sdf.format(date);

🎉 String转Date

String str = "2021-01-01 00:00:00";
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Date date = sdf.parse(str);
相关文章
|
9天前
|
缓存 NoSQL 关系型数据库
13- Redis和Mysql如何保证数据⼀致?
该内容讨论了保证Redis和MySQL数据一致性的几种策略。首先提到的两种方法存在不一致风险:先更新MySQL再更新Redis,或先删Redis再更新MySQL。第三种方案是通过MQ异步同步以达到最终一致性,适用于一致性要求较高的场景。项目中根据不同业务需求选择不同方案,如对一致性要求不高的情况不做处理,时效性数据设置过期时间,高一致性需求则使用MQ确保同步,最严格的情况可能涉及分布式事务(如Seata的TCC模式)。
35 6
|
1月前
|
SQL 关系型数据库 MySQL
Python怎么操作Mysql数据库
Python怎么操作Mysql数据库
49 0
|
17天前
|
存储 SQL 关系型数据库
【MySQL】4. 表的操作
【MySQL】4. 表的操作
20 0
|
1月前
|
SQL 关系型数据库 MySQL
|
16天前
|
存储 关系型数据库 MySQL
MySQL数据库性能大揭秘:表设计优化的高效策略(优化数据类型、增加冗余字段、拆分表以及使用非空约束)
MySQL数据库性能大揭秘:表设计优化的高效策略(优化数据类型、增加冗余字段、拆分表以及使用非空约束)
|
16天前
|
缓存 关系型数据库 MySQL
MySQL查询优化:提速查询效率的13大秘籍(合理使用索引合并、优化配置参数、使用分区优化性能、避免不必要的排序和group by操作)(下)
MySQL查询优化:提速查询效率的13大秘籍(合理使用索引合并、优化配置参数、使用分区优化性能、避免不必要的排序和group by操作)(下)
|
16天前
|
存储 缓存 NoSQL
Redis 服务器指南:高性能内存数据库的完整使用指南
Redis 服务器指南:高性能内存数据库的完整使用指南
|
22天前
|
NoSQL 关系型数据库 MySQL
安装Docker&镜像容器操作&使用Docker安装部署MySQL,Redis,RabbitMQ,Nacos,Seata,Minio
安装Docker&镜像容器操作&使用Docker安装部署MySQL,Redis,RabbitMQ,Nacos,Seata,Minio
102 1
|
23天前
|
存储 NoSQL Java
Redis 数据结构操作入门
Redis 数据结构操作入门
15 0
|
1月前
|
NoSQL 关系型数据库 MySQL
Docker安装详细步骤及相关环境安装配置(mysql、jdk、redis、自己的私有仓库Gitlab 、C和C++环境以及Nginx服务代理)
Docker安装详细步骤及相关环境安装配置(mysql、jdk、redis、自己的私有仓库Gitlab 、C和C++环境以及Nginx服务代理)
196 0