当前位置：文档之家 › 在Spring中发布自定义事件(精)

在Spring中发布自定义事件(精)

  • 格式：doc
  • 大小：18.00 KB
  • 文档页数：5

在Spring中发布自定义事件
(2008-01-24 08:53:11
在Java中，事件机制的实现包括三个基本组件，事件、事件发布者和事件监听者。在
Spring中，事件机制的实现也同样包括这三个基本组件，但Spring框架对这些组件实现了高层
封装和抽象，使得事件的发布过程非常的简单，而且降低了组件之间的耦合性。但事情总没有
完美的，事件组件和Spring框架之间的耦合则不可避免。不管怎样，Spring还是帮助我们简单
而优雅的实现了事件机制。下面就来看看如何在Spring中实现自定义事件的发布和监听。

假设这样一个场景：新学期开了一门新课，学生要通过注册取得上课的资格，课程不可能接
受太多的学生，当注册人数达到一定数量后，就不再允许注册这门课程了（我们这门新课只接

受7个学生，先到先得哦）。

先实现和事件没关系的组件——课程，代码如下：
public class Course {
public static final int MAX_CAPACITY = 7;
private int capacity = 0;
public Course( {}
public int getCapacity( {
return capacity;
}
public void addNewStudent( {
this.capacity++;
}
}
接着实现事件的三个基本组件，首先事件是事件机制的核心，先实现它。这里实现了两个事
件RegisteredEvent和CourseFullEvent，分别表示注册成功事件和课程已满事件。在Spring
中，所有事件都继承自抽象类ApplicationEvent。我们不需要这两个事件做什么，所以它们的
代码很简单。

public class RegisteredEvent extends ApplicationEvent {
public RegisteredEvent(Object arg0 {
super(arg0;
}
}
public class CourseFullEvent extends ApplicationEvent {
public CourseFullEvent(Object arg0 {
super(arg0;
}
}
第二个组件是事件发布者，也就是课程注册服务。在Spring中发布事件当然要通过容器来发
布，这样容器内的监听器组件才会知道事件发生了。BeanFactory容器没有发布事件的功能，
所以就要用特性更为丰富的ApplicationContext。而容器中的Java对象要想知道它所在的容
器，就一定要实现ApplicationContextAware接口，因此这个对象就难免要和Spring框架建立联
系了，为了实现发布事件的功能，与框架的耦合在所难免。

public interface StudentService {
void register(Course course, Student student;
}
public class StudentServiceImpl implements StudentService,
ApplicationContextAware {
private ApplicationContext context;
public void setApplicationContext(ApplicationContext arg0
throws BeansException {
this.context = arg0;
}
public void register(Course course, Student student {
int capacity = course.getCapacity(;
if (++capacity > Course.MAX_CAPACITY {
System.out.println("该课程已经人满，注册失败";
context.publishEvent(new CourseFullEvent(this;
} else {
course.addNewStudent(;
student.setStudentId(course.getCapacity(;
System.out.println("恭喜您，注册成功";
context.publishEvent(new RegisteredEvent(this;
}
}
}
Spring容器会自动地通过set方法把自己注入到实现了ApplicationContextAware接口的对象
中，这样StudentService的实现就可以通过所在的容器发布任何事件了，很简单，调用容器的
publishEvent方法并传入所要发布的事件就行了。

最后要实现的组件就是监听者了，也就是Student，它实现了ApplicationListener接口，并把
自己注册到Spring容器中。当事件发生时，容器会通知它里面的监听者，Student收到事件通
知，在onApplicationEvent方法中，判断事件类型，并对事件做出响应。Student的代码如下：

public class Student implements ApplicationListener {
private int studentId;

public Student( {}
public void onApplicationEvent(ApplicationEvent arg0 {
if (arg0 instanceof RegisteredEvent {
System.out.println("太好了，我注册的学号是" + this.studentId;
} else if (arg0 instanceof CourseFullEvent {
System.out.println("来晚了，我没注册上";
}
}

public void setStudentId(int studentId {
this.studentId = studentId;
}
}
当然，别忘了Spring的配置文件：

com.Student " />
com.Course " />
studentService "
class="com.StudentServiceImpl" />

最后，写个小应用运行一下，看看效果如何：
public class SpecialBeanApp {
public static void main(String[] args {
ApplicationContext ctx = new ClassPathXmlApplicationContext(
"applicationContext.xml";

// 开一门课
Course course = (Course ctx.getBean("course";

// 开启注册课程的服务
StudentService service = (StudentService ctx.getBean("studentService";

// 注册10个学生
for (int i = 0; i < 10; i++ {
Student student = (Student ctx.getBean("student";
service.register(course, student;
}
}
}
最后再说明一点，Spring的事件机制是同步的，也就是阻塞式的，所以，对事件的处理要尽
量简单快捷，否则会极大的影响应用程序的性能。我们期待着Spring2.0的后续版本能实现异
步的事件机制。

合集下载

SpringSecurity（十五）：会话管理

SpringSecurity（十五）：会话管理

SpringSecurity（⼗五）：会话管理当浏览器登录后，服务器和浏览器之间会建⽴⼀个会话（Session）, 浏览器在每次发送请求时都会携带⼀个SessionId,服务端根据这个SessionId判断⽤户⾝份。

浏览器关闭后Session不会⾃动销毁。

需要开发者⼿动在服务端调⽤Session销毁⽅法，或者等待Session过期⾃动销毁。

在Spring Security中与HttpSession有关的功能由SessionManagementFilter和SessionAuthenticationStrategy接⼝处理，SessionManagementFilter将Session相关操作委托给SessionAuthenticationStrategy接⼝去完成。

会话并发管理会话并发管理是指在当前系统中，同⼀个⽤户可以同时创建多少个会话，如果⼀台设备对应⼀个会话，也可以理解为同⼀个⽤户可以同时在多少个设备上进⾏登录。

在Spring Security中默认情况下，同⼀个⽤户在多少个设备上登录并没有限制，但是我们可以⾃⼰设置。

public class SecurityConfig extends WebSecurityConfigurerAdapter {@Overrideprotected void configure(HttpSecurity http) throws Exception {http.authorizeRequests().anyRequest().authenticated().and().formLogin().and().csrf().disable().sessionManagement().maximumSessions(1);}}(1)在configure(HttpSecurity)⽅法中通过sessionManagerment()⽅法开启会话配置，并设置并发数为1(2)提供⼀个httpSessionEventPublisher实例。

基于SpringBootAOP与自定义注解转义字典值

基于SpringBootAOP与自定义注解转义字典值

基于SpringBootAOP与自定义注解转义字典值要基于SpringBoot、AOP和自定义注解来转义字典值，可以按照以下步骤进行：1.创建一个字典表，存储字典值和对应的转义值。

例如，可以创建一个数据库表或者在配置文件中定义一个字典映射关系。

4.在切面方法中，获取需要转义的字段的值，然后根据字典表中的映射关系，找到对应的转义值，并将转义值设置回字段。

5.在需要使用转义值的地方，直接使用被转义后的字段值即可。

下面是一个简单的示例代码：1.创建字典表，例如在配置文件中定义：```yamldict.mapping:gender:0:男1:女``````javaString value( default "";```3.创建AOP切面类：```javapublic class DictTransAspectprivate DictMapping dictMapping;public Object dictTrans(ProceedingJoinPoint joinPoint) throws ThrowableObject result = joinPoint.proceed(;//获取被标记的字段或方法Field field =ReflectionUtils.findField(joinPoint.getTarget(.getClass(, ((MethodSignature) joinPoint.getSignature().getName();DictTrans dictTrans = field.getAnnotation(DictTrans.class);if (dictTrans != null)//获取字段值Object value = field.get(joinPoint.getTarget();//获取字段的字典映射关系Map<String, String> mapping =dictMapping.getMapping(dictTrans.value();//根据字典映射关系转义字段值String transValue = mapping.get(value.toString();//设置转义值回字段field.set(joinPoint.getTarget(, transValue);}return result;}``````javapublic class Userprivate Integer gender;// getter and setter```5.在业务中使用转义后的字段值：```javapublic class UserService// 注入 UserMapper 或者其他数据访问层public User getUserById(String id)User user = userMapper.findById(id);System.out.println(user.getGender(); // 输出转义后的值，例如输出 "男"return user;}```这样，就实现了基于 SpringBoot、AOP 和自定义注解来转义字典值的功能。

springboot自定义http反馈状态码

springboot自定义http反馈状态码

springboot⾃定义http反馈状态码最近在开发⼀些http server类型程序，通过spring boot构建⼀些web程序，这些web程序之间通过http进⾏数据访问、共享，如下图:假设现在client发起⼀次保存数据的请求到server，server可能会返回如下类似的数据:{"status":1,"message":"xxxxxx"}然后client通过解析json获得status来判断当前的请求操作是否成功，开发过程中通过都是这么做的，但是这样在restful设计中不怎么好，其实这个status字段的表达完全可以通过http status来表⽰，类似404、500、502这种都有明确的定义并且相互理解、沟通起来也⽅便。

⽂章主要记录⼀下我是如何在spring boot中实现⾃定反馈状态码的，以及我找到的三种实现⽅式。

第⼀种，使⽤@ResponseStatus这是⼀个注解，可以作⽤在⽅法和类上⾯，如下使⽤:在⽅法上使⽤⽅式:1 @RequestMapping(value = "/user", method = RequestMethod.GET)2 @ResponseStatus(code=HttpStatus.INTERNAL_SERVER_ERROR,reason="server error")3public String getUser(){4return "im zhangsan";5 }启动web程序，通过postman访问http://127.0.0.1:8100/user，会出现下⾯结果:{"timestamp": 1497850427325,"status": 500,"error": "Internal Server Error","message": "server error","path": "/user"}这⾥我⼀开始觉得很奇怪，为什么我的getUser⽅法中没有错误，结果还是出现了500错误？原因就是@ResponseStatus注解的问题，我后⾯猜测它会强制的将映射转化成500的状态码。

Spring的@Validation和javax包下的@Valid区别以及自定义校验注解

Spring的@Validation和javax包下的@Valid区别以及自定义校验注解

Spring的@Validation和javax包下的@Valid区别以及⾃定义校验注解1.后台参数校验Spring Validation验证框架对参数的验证机制提供了@Validated（Spring JSR-303规范，是标准JSR-303的⼀个变种），javax提供了@Valid（标准JSR-303规范），配合BindingResult可以直接提供参数验证结果spring提供的验证:org.springframework.validation.annotation.Validated;javax提供的验证:javax.validation.Valid;在检验Controller的⼊参是否符合规范时，使⽤@Validated或者@Valid在基本验证功能上没有太多区别。

但是在分组、注解地⽅、嵌套验证等功能上两个有所不同：1.1 分组@Validated：提供了⼀个分组功能，可以在⼊参验证时，根据不同的分组采⽤不同的验证机制，这个⽹上也有资料，不详述。

@Valid：作为标准JSR-303规范，还没有分组的功能。

1.2 注解地⽅@Validated：可以⽤在类型、⽅法和⽅法参数上。

但是不能⽤在成员属性（字段）上@Valid：可以⽤在⽅法、构造函数、⽅法参数和成员属性（字段）上两者是否能⽤于成员属性（字段）上直接影响能否提供嵌套验证的功能。

1.3 嵌套验证@Validated：⽤在⽅法⼊参上⽆法单独提供嵌套验证功能。

不能⽤在成员属性（字段）上，也⽆法提⽰框架进⾏嵌套验证。

能配合嵌套验证注解@Valid进⾏嵌套验证。

⽰例代码:#使⽤@Validated的分组功能,需要提供接⼝,原因是@Target({ElementType.TYPE, ElementType.METHOD,ElementType.PARAMETER})@Retention(RetentionPolicy.RUNTIME)@Documentedpublic @interface Validated {Class<?>[] value() default {}; #需要定义类型做区分,所以提供个接⼝做分组区分}⽰例分类接⼝:public interface CreateGroup {}#在需要验证的字段上添加分组即可⽰例代码:public class WebOrderQo {/*** ⽤户ID*/@ApiModelProperty("⽤户ID")@NotNull(message = "⽤户ID不能为空", groups = {UpdateGroup.class, CreateGroup.class, QueryGroup.class})private Long uid;}#在Controller⾥⾯的⽅法上加@Validated注解,启动分组需要在@Validated(CreateGroup.class)填上对应的分组类型,默认没有指定分组的校验注解@NotNull，在分组校验情况@Validated({CreateGroup.class})下不⽣效，只会在@Validated⽣效；⽰例代码:@RestControllerpublic class ItemController {@RequestMapping("/item/add")public void addItem(@Validated Item item, BindingResult bindingResult) {doSomething();}}@Valid：⽤在⽅法⼊参上⽆法单独提供嵌套验证功能。