Spring Boot使用WebSockets存储数据

debugcn 发表于 Dev

开发者

我有一个简单的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')
}

人控者

@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存储数据？
您是否知道有关存储数据的任何示例？我只能找到基本示例而不存储数据。

开发者

问题出在我的持久性配置中。我将配置从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

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。