----------------------------------------------------------------------------------------------------------------
springboot 详解 （一） helloworld 下载demo
springboot 详解 (四）redis & filter 下载demo
springboot 详解 (五）interceptor 下载demo
springboot 详解 (六）servlet & scheduled & listener 下载demo
springboot 详解（七） dubbox & zookeeper 下载（productor） 下载（constumser）
springboot 详解（八） springboot & springcloud
----------------------------------------------------------------------------------------------------------------
代码下载位置：https://download.csdn.net/download/knight_black_bob/10309215
public class MessageEvent extends ApplicationEvent{
private MSMMessageEnitity entity;
private boolean flag;
public MessageEvent(Object source,MSMMessageEnitity entity, boolean flag) {
super(source);
this.entity = entity;
}
public MSMMessageEnitity getEntity() {
return entity;
}
public void setEntity(MSMMessageEnitity entity) {
this.entity = entity;
}
public boolean isFlag() {
return flag;
}
public void setFlag(boolean flag) {
this.flag = flag;
}
}
public class MSMMessageEnitity implements Serializable{
private String msgId;
private Date sendDate;
private String content;
private String sendUserid;
public String getMsgId() {
return msgId;
}
public void setMsgId(String msgId) {
this.msgId = msgId;
}
public Date getSendDate() {
return sendDate;
}
public void setSendDate(Date sendDate) {
this.sendDate = sendDate;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
public String getSendUserid() {
return sendUserid;
}
public void setSendUserid(String sendUserid) {
this.sendUserid = sendUserid;
}
}
@Component
public class MessageListener implements ApplicationListener {
@Async
@Override
public void onApplicationEvent(ApplicationEvent event) {
if (event instanceof MessageEvent) {
sendMsmMessage();
}
}
private void sendMsmMessage() {
System.out.println("======================= send evnetlistener start =======================");
try {
Thread.sleep(3000);
//TODO:
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("======================= send evnetlistener success =======================");
}
}
@Service
public class SendMessageServiceImpl implements SendMessageService{
@Autowired
private ApplicationContext context;
@Override
public void send(MSMMessageEnitity entity) {
context.publishEvent(new MessageEvent(this, entity,true));
}
}
public interface SendMessageService {
public void send(MSMMessageEnitity entity);
}
@RestController
@RequestMapping("/messages")
public class MessageSendController {
@Resource
SendMessageService sendMessageService;
@RequestMapping("/send")
public void send(){
MSMMessageEnitity entity = new MSMMessageEnitity();
sendMessageService.send(entity );
System.out.println(" ================insert db=========================");
System.out.println("=====================end= end=======================");
}
}
@EnableAsync
@SpringBootApplication
public class SyncEvnetApplication {
public static void main(String[] args) {
SpringApplication.run(SyncEvnetApplication.class, args);
}
}
捐助开发者
在兴趣的驱动下,写一个免费的东西，有欣喜，也还有汗水，希望你喜欢我的作品，同时也能支持一下。 当然，有钱捧个钱场（支持支付宝和微信 以及扣扣群），没钱捧个人场，谢谢各位。
个人主页：http://knight-black-bob.iteye.com/
谢谢您的赞助，我会做的更好！
