SpringTemplate 使用

程序员朱永胜2023-09-242024-11-12

有的时候博客内容会有变动，首发博客是最新的，其他博客地址可能会未同步, 认准 https://blog.zysicyj.top

Spring Template 是 Spring 框架中的一个抽象概念，用于简化和促进与某些技术的集成与使用。Spring 框架通过提供模板类，减少了繁琐的样板代码，使开发者可以更加专注于业务逻辑。以下是一些常见的 Spring Template 及其功能：

1. JdbcTemplate

JdbcTemplate 是 Spring 框架中用于简化 JDBC 操作的模板类。它封装了常见的 JDBC 操作，如查询、更新和事务管理，减少了直接使用 JDBC API 时的样板代码。

使用示例

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;

public class JdbcTemplateExample {
    public static void main(String[] args) {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/testdb");
        dataSource.setUsername("root");
        dataSource.setPassword("password");

        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);

        // 插入数据 
        String insertSql = "INSERT INTO users (name, email) VALUES (?, ?)";
        jdbcTemplate.update(insertSql, "John Doe", "john.doe@example.com");

        // 查询数据 
        String selectSql = "SELECT name FROM users WHERE email = ?";
        String name = jdbcTemplate.queryForObject(selectSql, new Object[]{"john.doe@example.com"}, String.class);
        System.out.println("Name: " + name);
    }
}

2. RestTemplate

RestTemplate 是 Spring 提供的用于简化 RESTful Web 服务调用的模板类。它封装了 HTTP 请求和响应处理，使得与 RESTful 服务的交互变得更加容易。

使用示例

import org.springframework.web.client.RestTemplate;
import org.springframework.http.ResponseEntity;

public class RestTemplateExample {
    public static void main(String[] args) {
        RestTemplate restTemplate = new RestTemplate();

        // GET 请求 
        String url = "https://jsonplaceholder.typicode.com/posts/1";
        ResponseEntity<String> response = restTemplate.getForEntity(url, String.class);
        System.out.println("Response: " + response.getBody());

        // POST 请求 
        String postUrl = "https://jsonplaceholder.typicode.com/posts";
        String requestJson = "{\"title\":\"foo\",\"body\":\"bar\",\"userId\":1}";
        ResponseEntity<String> postResponse = restTemplate.postForEntity(postUrl, requestJson, String.class);
        System.out.println("Post Response: " + postResponse.getBody());
    }
}

3. JmsTemplate

JmsTemplate 是 Spring 提供的用于简化 JMS（Java Message Service）操作的模板类。它提供了发送和接收消息的便捷方法，隐藏了底层 JMS API 的复杂性。

使用示例

import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class JmsTemplateExample {
    public static void main(String[] args) {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        JmsTemplate jmsTemplate = new JmsTemplate(connectionFactory);

        // 发送消息 
        jmsTemplate.send("testQueue", new MessageCreator() {
            @Override
            public Message createMessage(Session session) throws JMSException {
                return session.createTextMessage("Hello, JMS!");
            }
        });

        // 接收消息 
        String message = (String) jmsTemplate.receiveAndConvert("testQueue");
        System.out.println("Received message: " + message);
    }
}

4. MongoTemplate

MongoTemplate 是 Spring Data MongoDB 提供的模板类，用于简化与 MongoDB 的交互。它提供了对 MongoDB 常见操作的封装，如查询、插入、更新和删除。

使用示例

import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;

public class MongoTemplateExample {
    public static void main(String[] args) {
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(MongoConfig.class);
        MongoTemplate mongoTemplate = context.getBean(MongoTemplate.class);

        // 插入文档 
        User user = new User("John", "john@example.com");
        mongoTemplate.insert(user, "users");

        // 查询文档 
        Query query = new Query();
        query.addCriteria(Criteria.where("email").is("john@example.com"));
        User retrievedUser = mongoTemplate.findOne(query, User.class, "users");
        System.out.println("Retrieved User: " + retrievedUser.getName());

        // 更新文档 
        Update update = new Update();
        update.set("name", "John Doe");
        mongoTemplate.updateFirst(query, update, User.class, "users");

        context.close();
    }
}