// 改造SecurityConfig

@EnableWebSecurity 
@EnableGlobalMethodSecurity(prePostEnabled = true)  // 启用方法级别的安全设置
public class SecurityConfig extends WebSecurityConfigurerAdapter {
	private static final String KEY = "rex.com";

	@Autowired
	private UserDetailsService userDetailsService;
	@Autowired
	private PasswordEncoder passwordEncoder;

	@Bean
	public PasswordEncoder passwordEncoder(){
		return new BCryptPasswordEncoder();
	}

	@Bean
	public AuthenticationProvider authenticationProvider(){
		DaoAuthenticationProvider authenticationProvider = new DaoAuthenticationProvider();
		authenticationProvider.setUserDetailsService(userDetailsService);
        // 加密设置
		authenticationProvider.setPasswordEncoder(passwordEncoder);
		return authenticationProvider;
	}
	/**
	 * 自定义配置
	 * @param http
	 * @throws Exception
	 */
	@Override
	protected void configure(HttpSecurity http) throws Exception {
		http.authorizeRequests().antMatchers("/css/**", "/js/**", "/fonts/**", "/index").permitAll().antMatchers("/h2-consele/**").permitAll()
				// 相应角色访问
				.antMatchers("/admins/**").hasRole("ADMIN").and()
				// 基于表单登录验证
				.formLogin()
				// 自定义登录界面
				.loginPage("/login").failureUrl("/login-error")
				// 启用remember-me
				.and().rememberMe().key(KEY)
				// 处理异常,拒绝访问就重定向到403
				.and().exceptionHandling().accessDeniedPage("/403");
		http.csrf().ignoringAntMatchers("/h2-console/**");
		http.headers().frameOptions().sameOrigin();
	}

	/**
	 * 认证信息管理
	 * @param auth
	 * @throws Exception
	 */
	public void configureGlobal(AuthenticationManagerBuilder auth) throws Exception{
		auth.userDetailsService(userDetailsService);
		auth.authenticationProvider(authenticationProvider());
	}
}

// 修改UserServiceImpl
@Service
public class UserServiceImpl implements UserService,UserDetailsService{
	@Override
	public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
		return userRepository.findByUsername(username);
	}
}

// 添加 Markdown parser 依赖
compile('es.nitaur.markdown:txtmark:0.16')

// 添加文件服务器 application.properties
# 文件服务器
file.server.url=http://localhost:8081/upload

// UserspaceController
@GetMapping("/{username}/profile")
@PreAuthorize("authentication.name.equals(#username)")
public ModelAndView profile(@PathVariable("username")String username,Model model){
    User user = (User)userDetailsService.loadUserByUsername(username);
    model.addAttribute("user",user);
    model.addAttribute("fileServerUrl",fileServerUrl);
    return new ModelAndView("/userspace/profile","userModel",model);
}

@PostMapping("/{username}/profile")
@PreAuthorize("authentication.name.equals(#username)")
public String profile(@PathVariable("username") String username, User user) {
    User originalUser = userService.getUserById(user.getId());
    originalUser.setEmail(user.getEmail());
    originalUser.setName(user.getName());
    // 判断密码是否更改
    String rawPassword = originalUser.getPassword();
    PasswordEncoder encoder = new BCryptPasswordEncoder();
    String encodePassword = encoder.encode(user.getPassword());
    boolean isMatch = encoder.matches(rawPassword, encodePassword);
    if (!isMatch) {
        originalUser.setEncodePassword(user.getPassword());
    }
    userService.saveOrUpdateUser(originalUser);
    return "redirect:/u/" + username + "/profile";
}

// Blog.java
@Entity
public class Blog {...}

// BlogRepository.java
public interface BlogRepository extends JpaRepository<Blog,Long> {...}

// BlogServiceImpl.java
@Service
public class BlogServiceImpl implements BlogService {...}

// Modify UserspaceController.java
@GetMapping("/{username}")
public String userSpace(@PathVariable("username") String username, Model model) {...}

@GetMapping("/{username}/blogs")
	public String listBlogsByOrder(@PathVariable("username") String username, 
                                   @RequestParam(value = "order", required = false, defaultValue = "new") String order, 
                                   @RequestParam(value = "category", required = false) Long catalogId, 
                                   @RequestParam(value = "keyword", required = false, defaultValue = "") String keyword, 
                                   @RequestParam(value = "async", required = false) boolean async, 
                                   @RequestParam(value = "pageIndex", required = false, defaultValue = "0") int pageIndex, 
                                   @RequestParam(value = "pageSize", required = false, defaultValue = "10") int pageSize, 
                                   Model model) {...}

@GetMapping("/{username}/blogs/{id}")
public String getBlogById(@PathVariable("username") String username, 
                          @PathVariable("id") Long id, Model model) {...}


@GetMapping("/{username}/blogs/edit")
public ModelAndView createBlog(@PathVariable("username")String username,Model model) {...}

POST 	/register
GET		/register(User)
GET		/users(async,pageIndex,pageSize,name);
GET		/users/add;
POST 	/users;
DELETE	/users/{id};
GET		/users/edit/{id};

// 修改User实体
@NotEmpty(message = "姓名不能为空")
@Size(min = 2, max = 20)
@Column(nullable = false, length = 20)

// 新增Authority实体
@Entity
public class Authority implements GrantedAuthority{...}

// 编写Repository
public interface UserRepository extends JpaRepository<User,Long> {...}
public interface AuthorityRepository extends JpaRepository<Authority,Long> {...}

// 完成Service
public interface UserService {...}

// 完成Impl
@Service
public class UserServiceImpl implements UserService {...}

// VO
public class Response {...}

// Util
public class ConstraintViolationExceptionHandler {
	/**
	 * 获取批量异常信息
	 * @param e
	 * @return
	 */
	public static String getMessage(ConstraintViolationException e){
		List<String> msgList = new ArrayList<>();
		for(ConstraintViolation<?> constraintViolation : e.getConstraintViolations()){
			msgList.add(constraintViolation.getMessage());
		}
		String messages = StringUtils.join(msgList.toArray(),";");
		return messages;
	}
}

// 对应Controller
AdminController,MainController,UserController
// 前端页面
略

// 添加 Spring Security 依赖
compile('org.springframework.boot:spring-boot-starter-security')
// 添加 Thymeleaf Spring Security 依赖
compile('org.thymeleaf.extras:thymeleaf-extras-springsecurity4:3.0.2.RELEASE')

// 安全配置类
@EnableWebSecurity
public class SecurityConfig extends WebSecurityConfigurerAdapter {
@Override
protected void configure(HttpSecurity http) throws Exception {
    http.authorizeRequests()
        .antMatchers("/css/**","/js/**","/fonts/**","/index").permitAll()  // 可访问
        .antMatchers("/users/**").hasRole("ADMIN")  // 需要角色
        .and()
        .formLogin()  // 基于FORM表单登录验证
        .loginPage("/login").failureUrl("/login-error");  // 自定义登录界面
}
@Autowired
public void configureGlobal(AuthenticationManagerBuilder auth) throws Exception{
    // 认证信息管理 存储于内存中
    auth.inMemoryAuthentication().withUser("admin").password("123123").roles("ADMIN");
}
}

// 控制器
@Controller
public class MainController {
	@GetMapping("/")
	public String root(){...}

	@GetMapping("/index")
	public String index(){...}

	@GetMapping("/login")
	public String login(){...}

	@GetMapping("/login-error")
	public String loginError(Model model){...}
}

// 获取EntityManager实例
@PersistenceUnit // 持久化单元
EntityManagerFactory emf;
EntityManager em;
@Resource
UserTransaction utx;
...
em = emf.createEntityManager();
try{
    utx.begin();
    em.persist(SomeEntity);
    em.merge(AnotherEntity);
    em.remove(ThirdEntity);
    utx.commit();
}catch(Exception e){
    utx.rollback();
}

// 查找实体
@PersistenceContext
EntityManager em;
public void enterOrder(int custID,CustomerOrder newOrder){
    Customer cust = em.find(Customer,custID);
    cust.getOrders().add(newOrder);
    newOrder.setCustomer(cust);
}

@Entity
@Id
@GeneratedValue(strategy= GenerationType.IDENTITY)
// Controller
findAll();
findOne();
delete();
save();
// application.properties
# 使用H2控制台：
spring.h2.console.enabled=true
#查看
localhost:8080/h2-console
// application.properties
# DataSource
spring.datasource.url=...
spring.datasource.username=...
spring.datasource.password=...
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
# JPA
spring.jpa.show-sql=true
spring.jpa.hibernate.ddl-auto=create-drop

// build.gradle

// 添加 Spring Daat Elasticsearch 的依赖
compile('org.springframework.boot:spring-boot-starter-data-elasticsearch')
// 添加 JNA 的依赖
compile('net.java.dev.jna:jna:4.3.0')
    
// application.properties
# Elasticsearch 服务地址
spring.data.elasticsearch.cluster-nodes=localhost:9300
# 设置连接超时时间
spring.data.elasticsearch.properties.transport.tcp.connect_timeout=120s

// domain
@Document(indexName="blog",type="blog")
    
// repository
public interface EsBlogRepository extends ElasticsearchRepository<EsBlog,String> {...}

进行controller之前，需要启动elasticsearch服务器
PS：注意jar包的版本，以及elasticsearch服务器的版本问题

// controller
@GetMapping
public List<EsBlog> list(@RequestParam(value = "title")String title,
                         @RequestParam(value = "summary")String summary,
                         @RequestParam(value = "content")String content,
                         @RequestParam(value = "pageIndex",defaultValue = "0")int pageIndex,
                         @RequestParam(value = "pageSize",defaultValue = "10")int pageSize){
    // 数据在测试用例中初始化
    Pageable pageable = new PageRequest(pageIndex, pageSize);
    Page<EsBlog> page = esBlogRepository.find...(title,summary,content,pageable);
    return page.getContent();
}

public static void Array(int ... intArray){}

public class ThreadTest extends Thread{
    public void run(){  
        // ...  
    }
    public static void main(String[] args){
        new ThreadTest().start();
    }
}

public class RunnableThread implements Runnable{
    @Override
    public void run(){
        //...
    }
    public static void main(String[] args){
        RunnableThread run = new RunnableThread();
        new Thread(run,"ThreadName").start();
    }
}

public class UDPClient{
    public static void main(String[] args) throws Exception{
        int port = 12345;
        InetAddress address = InetAddress.getByName("localhost");
        String data = "hello";
        byte[] dataToSend = data.getBytes();
        DatagramSocket socket = new DatagramSocket();
        DatagramPakcet sendPacket = new                                                                                      DatagramPacket(dataToSend,dataToSend.length,address,port);
        socket.send(sendPacket);
        socket.close();
    }
}

public class UDPServer{
    public static void main(String[] args) throws Exception{
        int port = 12345;
        DatagramSocket socket = new DatagramSocket(port);
        DatagramPacket inPacket = new DatagramPacket(new byte[256],256);
        while(true){
            socket.receive(inPacket);
            System.out.println(inPacket.getData().toString());
        }
    }
}

// 同步代码块
public class DrawThread extends Thread{
    public void run{
        synchronized(account){
            if(account.getBalance() >= drawAmount)
                System.out.println("取钱成功");
            else
                System.out.println("取钱失败");
        }
    }
}

// 同步方法
public class Account{
    public synchronized void draw(double drawAmount){
        if(account.getBalance() >= drawAmount)
            System.out.println("取钱成功");
        else
            System.out.println("取钱失败");
    }
}

public class JDBC{
    public static void main(String[] args) throws Exception{
		String URL = "jdbc:mysql://127.0.0.1:3306/studentdb?user=student&password=student";
		Connection con = null;
		Statement stmt = null;
		ResultSet rs = null;
        try{
            Class.forName("com.mysql.jdbc.Driver");
            con = DriverManager.getConnection(URL);
            stmt = con.createStatement();
            rs = stmt.executeQuery("select * from student");
            while(rs.next()){
                System.out.println("学号" + rs.getString("studentId") +                                                                              "姓名" + rs.getString("studentName"));
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            rs.close();
            stm.close();
            con.close();
        }
    }
}

public class Client{
    public static void main(String[] args) throws Exception{
        Socket socket = new Socket("127.0.0.1",30000);
        // DOUBLE
        DataOutputStream dos = new DataOutputStream(new BufferedOutputStream(socket.getOutputStream()));
        dos.writeDouble(10.123);
        dos.flush();
        // OBJECT
        ObjectOutputStream oos = new ObjectOutputStream(new BufferedOutputStream(socket.getOutputStream()));
        oos.writeObject(new Student("studentName",20));
        // FILE
        byte[] buff = new byte[32];
        BufferedInputStream bis = new BufferedInputeStream(new FileInputStream("\tx"));
        bis.read(buff,0,buff.length);
        OutputStream os = socket.getOutputStream();
        os.write(buff,0,buff.length);
        os.flush();socket.close;
    }
}

public class Server{
    public static void main(String[] args) throws Exception{
        ServerSocket socket = new ServerSocket(30000);
        while(true){
            Socket s = socket.accept();
            // DOUBLE
            DataInputStream dis = new DataInputStream(new BufferedInputStream(s.getInputStream()));
            Double d = dis.readDouble();       
            // OBJECT
            ObjectInputStream ois = new ObjectInputStream(new BufferedInputStream(s.getInputStream()));
            try{
                Student stu = (Student)ois.readObject();
                System.out.println("姓名"+ stu.getName() + "年龄" + stu.getAge());
            }catch(Exception e){
                e.printStackTrace();
            }
            // FILE
            byte[] buff = new byte[32];
            InputStream is = s.getInputStream();
            int byteRead = is.read(buff,0,buff.length);
            BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("/tx"));
            bos.write(buff,0,buff.length);

            bos.flush();
            bos.close();
            s.close();
        }
    }
}

public class Server{
    public static void main(String[] args){
        try{
           ServerSocket ss = new ServerSocket(30000);
           Socket s = ss.accept();
           BufferedReader br =new BufferedReader(new InputStreamReader(s.getInputStream()));
           String msg = br.readLine();
           System.out.println("客户端：" + msg);
           BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
           bw.write("ehco" + msg);
           bw.flush();
        }catch (Exception e){
           e.printStackTrace();
        }
    }
}

public class Client{
    public static void main(String[] args){
        try{
           Socket s = new Socket("127.0.0.1",30000);
           BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
           bw.write("测试消息文本");
           BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
           String echo = br.readLine();
           System.out.println("服务器：" + echo);
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

public class Singleton{
    private Singleton(){}
    private static Singleton instance = new Singleton();
    public static Singleton getInstance(){
        return instance;
    }
}

public class Singleton{
    private static Singleton instance = null;
    public static synchronized Singleton getInstance(){
        if(instance == null)
            instance = new Singleton();
      	return instance;
    }
}

public interface Repository<T,ID extends Serializable>{
    
}

public interface JpaRepository<T,ID extends Serializable> extends PagingAndSortingRepository<T,ID>{
    List<T> findAll();
    
    List<T> findAll(Sort sort);
    
    <S extends T> List<S> save(Iterable<S> entities);
    
    void flush();
    
    T saveAndFlush(T entity);
    
    void deleteInBatch(Iterable<T> entities);
    
    void deleteAllInBatch();
}

@Repository
public interface StudentRepository extends JpaRepository<Student, String>{
    // 这里的两个参数 填写对应的实体类和实体ID字段的数据类型
    
    // 举例说明 通过性别查找所有的男同学和女同学
    List<Student> findAllStudentsByGender(Integer gender);
    
    // 通过Pageable达到分页的查询效果
    Page<Student> findAllStudentsByGender(Integer gender,Pageable pageable);
}