Spring Boot使用WebSockets存储数据

Question

我设置了一个简单的WebSocket并尝试保存数据。不知怎的，数据没有持久化。我没有收到任何错误消息，对象会正确返回给客户端。如果我尝试用REST控制器和REST请求来存储对象，它就可以工作了。

以下是我的build.gradle文件的依赖项：

dependencies {
compile 'org.springframework.boot:spring-boot-starter-web'
compile 'org.springframework.boot:spring-boot-starter-data-jpa'
compile 'org.springframework.boot:spring-boot-starter-websocket'
compile 'org.springframework:spring-messaging'
compile 'com.google.code.gson:gson:1.7.2'
compile 'org.postgresql:postgresql:9.4-1200-jdbc41'
compile 'commons-dbcp:commons-dbcp:1.4'
testCompile('org.springframework.boot:spring-boot-startet-test')
}

PersonController

@Controller
public class PersonController {
    @Autowired
    PersonRepository personRepository;
    @MessageMapping("/test")
    @SendTo("/response/test")
    public Person test() throws Exception {
        Person person = new Person();
        person.setName("John Doe");
        return personRepository.save(person);
    }
}

STOMP消息的配置

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/response");
        config.setApplicationDestinationPrefixes("/app");
    }
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/websocket")
                .setAllowedOrigins("*")
                .withSockJS();
    }

个人实体

@Entity
public class Person {
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private long id;
    private String name;
    public long getId() {
        return id;
    }
    public void setId(long id) {
        this.id = id;
    }
    public String getName() {
        return getName;
    }
    public void setName(String name) {
        this.name = name;
    }
}

基本存储库

@NoRepositoryBean
public interface BaseRepository<T, ID extends Serializable> extends Repository<T, ID> {
    void delete(T deleted);
    void delete(ID id);
    Iterable<T> findAll();
    T findOne(ID id);
    T save(T persisted);
    Iterable<T> save(Iterable<T> persited);
}

人员存储库

public interface PersonRepository extends
        BaseRepository<Person, Serializable> {
}

• 我的代码有问题吗
• 缓存有问题吗？我必须强制冲洗吗
• SpringBoot是否支持使用WebSockets存储数据
• 你知道存储数据的例子吗？在没有存储数据的情况下，我只能找到基本的示例

Answer 1

问题出在我的持久性配置中。我将配置从Java实现更改为application.properties文件。我想我的交易经理有问题。

为了完成，这里是我当前的application.properties文件：

spring.datasource.url = jdbc:postgresql://localhost:5432/test
spring.datasource.username = test
spring.datasource.password = test
spring.datasource.testWhileIdle = true
spring.datasource.validationQuery = SELECT 1
spring.jpa.show-sql = true
spring.jpa.hibernate.ddl-auto = create
spring.jpa.hibernate.naming-strategy = org.hibernate.cfg.ImprovedNamingStrategy
spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.PostgreSQLDialect