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

简单构建发布脚本

2018年3月2日 | Leave a comment

问题：解决：

#!/bin/bash
# 构建打包上传 并重启 

# /home/wms/start.sh begin
##!/bin/bash
#cd `dirname $0`
#nohup java -jar wms.war >> wms.log 2>&1 &
# start.sh end

#
mvn clean -DskipTests=true install package
scp -i ../docs/dev1 target/wms.war root@122.152.200.229:/root/
pid=`ssh -i ../docs/dev1 root@122.152.200.229 ps aux |grep java|grep -i wms|awk '{print $2}'`
echo $pid
ssh -i ../docs/dev1 root@122.152.200.229 kill $pid
ssh -i ../docs/dev1 root@122.152.200.229 cp /root/wms.war /home/wms/
ssh -i ../docs/dev1 root@122.152.200.229 /home/wms/start.sh

#!/bin/bash

# 构建打包上传并重启

# /home/wms/start.sh begin

##!/bin/bash

#cd `dirname $0`

#nohup java -jar wms.war >> wms.log 2>&1 &

# start.sh end

mvn clean -DskipTests=true install package

scp -i ../docs/dev1 target/wms.war root@122.152.200.229:/root/

pid=`ssh -i ../docs/dev1 root@122.152.200.229 ps aux |grep java|grep -i wms|awk '{print $2}'`

echo $pid

ssh -i ../docs/dev1 root@122.152.200.229 kill $pid

ssh -i ../docs/dev1 root@122.152.200.229 cp /root/wms.war /home/wms/

ssh -i ../docs/dev1 root@122.152.200.229 /home/wms/start.sh

spring boot 启用 cache

2018年2月24日 | Leave a comment

问题： spring boot 启用 cache 解决：增加 @EnableCaching [… Read More

IT问题

程序员的疑难杂症录