liquibase 生成 changelog

2018年3月20日 | Leave a comment

问题：解决：对当前数据库状态生成 changlog [crayon-6746e… Read More

spring boot + jsp demo

2018年3月19日 | Leave a comment

问题：解决： http://idorobot.com:10080/demo/spring-bo… Read More

docker + selenium + java demo

2018年3月19日 | 2 Comments

问题：解决：用docker 启动 selenium hub & node , jav… Read More

linux 以其他用户启动 java 程序

2018年3月16日 | Leave a comment

解决：

useradd -M -N java
runuser -l java -c 'java -cp **** ****'

1 2	useradd -M -N java runuser -l java -c 'java -cp ** **'

参考： http://… Read More

flyway +maven demo

2018年3月15日 | Leave a comment

问题： flyway 可以管理数据库升级记录 changelog 可以使用java编写，本文章采用 sql … Read More

0000-00-00 can not be represented as java.sql.Data

2018年3月12日 | Leave a comment

问题： 0000-00-00 can not be represented as java.sql.Data … Read More

Spring 事件驱动 @EventListener & ApplicationEventPublisher demo

2018年3月9日 | Leave a comment

解决：不用 MQ 在 JVM spring 内进行event 发布订阅 App.java [crayon-6… Read More

Spring Boot + RabbitMQ demo

2018年3月9日 | Leave a comment

解决：

package demo.spmq1;

import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.logging.Logger;
import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.Binding.DestinationType;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@SpringBootApplication
@EnableScheduling
public class App {

    private static final Logger LOG = Logger.getLogger(Sender.class.getName());

    public static void main(String[] argv) {
        SpringApplication.run(App.class, argv);
    }

    @Component
    @Lazy(false)
    public static class Sender {

        final AmqpTemplate template;
        final AmqpAdmin admin;

        @Autowired
        public Sender(AmqpTemplate template, AmqpAdmin admin) {
            this.template = template;
            this.admin = admin;
            this.admin.declareExchange(new TopicExchange("ex1"));
            this.admin.declareQueue(new Queue("q2"));
            final Queue q1 = this.admin.declareQueue();
            this.admin.declareBinding(new Binding("q2", DestinationType.QUEUE, "ex1", "", null));
            this.admin.declareBinding(new Binding(q1.getName(), DestinationType.QUEUE, "ex1", "", null));
        }

        @Scheduled(fixedRate = 1000)
        public void send() {
            LOG.info("send begin");
            final Map<String, Object> map = new HashMap<>();
            map.put("one", 1);
            map.put("t", new Date());
            map.put("name", "你好");
            template.convertAndSend("ex1", "", map);
        }
    }

    @Component
    @Lazy(false)
    public static class R2 {
//        @RabbitListener(bindings = {
//            @QueueBinding(exchange = @Exchange("ex1"), value = @Queue())})

        @RabbitListener(queues = {"q2"})
        public void onrecv(Map map) {
            System.out.println("R2 recv:" + map);
        }
    }
}

package demo.spmq1;

import java.util.Date;

import java.util.HashMap;

import java.util.Map;

import java.util.logging.Logger;

import org.springframework.amqp.core.AmqpAdmin;

import org.springframework.amqp.core.AmqpTemplate;

import org.springframework.amqp.core.Binding;

import org.springframework.amqp.core.Binding.DestinationType;

import org.springframework.amqp.core.Queue;

import org.springframework.amqp.core.TopicExchange;

import org.springframework.amqp.rabbit.annotation.RabbitListener;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.context.annotation.Lazy;

import org.springframework.scheduling.annotation.EnableScheduling;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

@SpringBootApplication

@EnableScheduling

public class App {

private static final Logger LOG = Logger.getLogger(Sender.class.getName());

public static void main(String[] argv) {

SpringApplication.run(App.class, argv);

}

@Component

@Lazy(false)

public static class Sender {

final AmqpTemplate template;

final AmqpAdmin admin;

@Autowired

public Sender(AmqpTemplate template, AmqpAdmin admin) {

this.template = template;

this.admin = admin;

this.admin.declareExchange(new TopicExchange("ex1"));

this.admin.declareQueue(new Queue("q2"));

final Queue q1 = this.admin.declareQueue();

this.admin.declareBinding(new Binding("q2", DestinationType.QUEUE, "ex1", "", null));

this.admin.declareBinding(new Binding(q1.getName(), DestinationType.QUEUE, "ex1", "", null));

}

@Scheduled(fixedRate = 1000)

public void send() {

LOG.info("send begin");

final Map<String, Object> map = new HashMap<>();

map.put("one", 1);

map.put("t", new Date());

map.put("name", "你好");

template.convertAndSend("ex1", "", map);

}

@Component

@Lazy(false)

public static class R2 {

// @RabbitListener(bindings = {

// @QueueBinding(exchange = @Exchange("ex1"), value = @Queue())})

@RabbitListener(queues = {"q2"})

public void onrecv(Map map) {

System.out.println("R2 recv:" + map);

}

&nbs… Read More

【转】logback 配置

2018年3月7日 | Leave a comment

https://www.jianshu.com/p/44154e96608b [c… Read More

Spring Boot + security + 定制 userDetailsService

2018年3月5日 | Leave a comment

问题：解决： demo 定制 UserDetailsService [crayo… Read More

IT问题

程序员的疑难杂症录