update

Author: kimmking

03concurrency/0301/src/main/java/java0/conc0303/Homework03.java

@@ -14,6 +14,7 @@ public class Homework03 {
     public static void main(String[] args) {
 
         long start=System.currentTimeMillis();
+
         // 在这里创建一个线程或线程池，
         // 异步执行 下面方法
 

04fx/spring01/pom.xml

@@ -152,11 +152,6 @@
             <scope>test</scope>
         </dependency>
 
-        <dependency>
-            <groupId>org.springframework</groupId>
-            <artifactId>spring-jms</artifactId>
-            <version>4.3.29.RELEASE</version>
-        </dependency>
         <dependency>
             <groupId>org.apache.activemq</groupId>
             <artifactId>activemq-client</artifactId>

04fx/spring01/src/main/java/io/kimmking/spring01/GuavaDemo.java

@@ -79,7 +79,7 @@ public static void main(String[] args) throws IOException {
         // SPI+service loader
         // Callback/Listener
         // 
-        Student student2 = new Student(2, "KK02");
+        Student student2 = new Student(2, "KK02", null, null);
         System.out.println("I want " + student2 + " run now.");
         bus.post(new AEvent(student2));
 

04fx/spring01/src/main/java/io/kimmking/spring01/LombokDemo.java

@@ -16,7 +16,7 @@ public static void main(String[] args) throws IOException {
         student1.setName("KK01");
         System.out.println(student1.toString());
 
-        Student student2 = new Student(2, "KK02");
+        Student student2 = new Student(2, "KK02", null, null);
         System.out.println(student2.toString());
     }
 

04fx/spring01/src/main/java/io/kimmking/spring01/Student.java

@@ -5,6 +5,10 @@
 import lombok.Data;
 import lombok.NoArgsConstructor;
 import lombok.ToString;
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.BeanNameAware;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
 
 import java.io.Serializable;
 
@@ -13,17 +17,29 @@
 @AllArgsConstructor
 @NoArgsConstructor
 @ToString
+public class Student implements Serializable, BeanNameAware, ApplicationContextAware {
+
 
-public class Student implements Serializable {
-    
     private int id;
     private String name;
+
+    private String beanName;
+    private ApplicationContext applicationContext;
 
     public void init(){
         System.out.println("hello...........");
     }
 
-    public Student create(){
-        return new Student(101,"KK101");
+//    public Student create(){
+//        return new Student(101,"KK101");
+//    }
+
+    public void print() {
+        System.out.println(this.beanName);
+        System.out.println("   context.getBeanDefinitionNames() ===>> "
+                + String.join(",", applicationContext.getBeanDefinitionNames()));
+
     }
+
+
 }

04fx/spring01/src/main/java/io/kimmking/spring02/SpringDemo01.java

@@ -14,9 +14,13 @@ public static void main(String[] args) {
 
         Student student123 = (Student) context.getBean("student123");
         System.out.println(student123.toString());
+
+        student123.print();
 
         Student student100 = (Student) context.getBean("student100");
         System.out.println(student100.toString());
+
+        student100.print();
 
         Klass class1 = context.getBean(Klass.class);
         System.out.println(class1);

04fx/spring01/src/main/java/io/kimmking/springjms/JmsSender.java

@@ -8,7 +8,7 @@ public class JmsSender {
 
     public static void main( String[] args )
     {
-        Student student2 = new Student(200, "KK0200");
+        Student student2 = new Student(201, "KK0201", null, null);
 
         ApplicationContext context = new ClassPathXmlApplicationContext("classpath:springjms-sender.xml");
 

04fx/spring01/src/main/java/io/kimmking/springjms/SendService.java

@@ -1,5 +1,6 @@
 package io.kimmking.springjms;
 
+import com.alibaba.fastjson.JSON;
 import io.kimmking.spring01.Student;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.jms.core.JmsTemplate;
@@ -19,7 +20,7 @@ public void send(final Student user) {
         jmsTemplate.send("test.queue", new MessageCreator() {
 
             public Message createMessage(Session session) throws JMSException {
-                return session.createObjectMessage(user);
+                return session.createObjectMessage(JSON.toJSONString(user));
             }
         });
     }