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

文章目录 🌟 如何优雅地写出高质量的Java代码🍊 设计模式🎉 单例模式🎉 工厂模式🎉 观察者模式 🍊 操作Redis🎉 连接Redis🎉 存储数据🎉 获取数据🎉 删除数据🎉 关闭连接 🍊 操作MySQL数据库🎉 连接MySQL🎉 插入数据🎉 查询数据🎉 更新数据🎉 删除数据🎉 关闭连接 🍊 各种MQ🎉 ActiveMQ🎉 RabbitMQ🎉 Kafka 🍊 数据类型转换🎉 String转int🎉 int转String🎉 String转double🎉 double转String🎉 Date转String🎉 String转Date

📕我是廖志伟，一名Java开发工程师、Java领域优质创作者、CSDN博客专家、51CTO专家博主、阿里云专家博主、清华大学出版社签约作者、产品软文创造者、技术文章评审老师、问卷调查设计师、个人社区创始人、开源项目贡献者。🌎跑过十五公里、徒步爬过衡山、🔥有过三个月减肥20斤的经历、是个喜欢躺平的狠人。

📘拥有多年一线研发和团队管理经验，研究过主流框架的底层源码(Spring、SpringBoot、Spring MVC、SpringCould、Mybatis、Dubbo、Zookeeper)，消息中间件底层架构原理(RabbitMQ、RockerMQ、Kafka)、Redis缓存、MySQL关系型数据库、 ElasticSearch全文搜索、MongoDB非关系型数据库、Apache ShardingSphere分库分表读写分离、设计模式、领域驱动DDD、Kubernetes容器编排等。🎥有从0到1的高并发项目经验，利用弹性伸缩、负载均衡、报警任务、自启动脚本，最高压测过200台机器，有着丰富的项目调优经验。

希望各位读者大大多多支持用心写文章的博主，现在时代变了，信息爆炸，酒香也怕巷子深，博主真的需要大家的帮助才能在这片海洋中继续发光发热，所以，赶紧动动你的小手，点波关注❤️，点波赞👍，点波收藏⭐，甚至点波评论✍️，都是对博主最好的支持和鼓励！

💂 博客主页： 我是廖志伟👉开源项目：java_wxid🌥 哔哩哔哩：我是廖志伟🎏个人社区：幕后大佬🔖个人微信号： SeniorRD

📥博主的人生感悟和目标

🍋程序开发这条路不能停，停下来容易被淘汰掉，吃不了自律的苦，就要受平庸的罪，持续的能力才能带来持续的自信。我本是是一个很普通程序员，放在人堆里，除了与生俱来的盛世美颜，就剩180的大高个了，就是我这样的一个人，默默写博文也有好多年了。📺有句老话说的好，牛逼之前都是傻逼式的坚持，希望自己可以通过大量的作品、时间的积累、个人魅力、运气、时机，可以打造属于自己的技术影响力。💥内心起伏不定，我时而激动，时而沉思。我希望自己能成为一个综合性人才，具备技术、业务和管理方面的精湛技能。我想成为产品架构路线的总设计师，团队的指挥者，技术团队的中流砥柱，企业战略和资本规划的实战专家。🎉这个目标的实现需要不懈的努力和持续的成长，但我必须努力追求。因为我知道，只有成为这样的人才，我才能在职业生涯中不断前进并为企业的发展带来真正的价值。在这个不断变化的时代，我必须随时准备好迎接挑战，不断学习和探索新的领域，才能不断地向前推进。我坚信，只要我不断努力，我一定会达到自己的目标。

📙经过多年在CSDN创作上千篇文章的经验积累，我已经拥有了不错的写作技巧。同时，我还与清华大学出版社签下了四本书籍的合约，并将陆续在明年出版。这些书籍包括了基础篇、进阶篇、架构篇的📌《Java项目实战—深入理解大型互联网企业通用技术》📌，以及📚《解密程序员的思维密码–沟通、演讲、思考的实践》📚。具体出版计划会根据实际情况进行调整，希望各位读者朋友能够多多支持！

🌾阅读前，快速浏览目录和章节概览可帮助了解文章结构、内容和作者的重点。了解自己希望从中获得什么样的知识或经验是非常重要的。建议在阅读时做笔记、思考问题、自我提问，以加深理解和吸收知识。阅读结束后，反思和总结所学内容，并尝试应用到现实中，有助于深化理解和应用知识。与朋友或同事分享所读内容，讨论细节并获得反馈，也有助于加深对知识的理解和吸收。

🔔如果您需要转载或者搬运这篇文章的话，非常欢迎您私信我哦~

💡在这个美好的时刻，本人不再啰嗦废话，现在毫不拖延地进入文章所要讨论的主题。接下来，我将为大家呈现正文内容。

🌟 如何优雅地写出高质量的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 mon.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka mon.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);