2006年7月4日

                   how to setup jacorb dev env
1:download JacORB_2_2

       http://www.jacorb.org/download.html
  download ant
       http://ant.apache.org/bindownload.cgi

2:extact JacORB_2_2.jar to d:\JacORB_2_2

3:setup sys environment

       set ANT_HOME=
       set JAVA_HOME=
       set JACORB_HOME=d:\JacORB_2_2
       set PATH=%PATH%;%ANT_HOME%\bin;%JAVA_HOME%\bin;%JACORB_HOME%\bin;
       set CLASSPAHT=.;%CLASSPAHT%;%ANT_HOME%\lib\ant.jar;%JACORB_HOME%\lib\jarorb.jar;%JACORB_HOME%\lib\idl.jar\;%JACORB_HOME%\lib\logkit-1.2.jar

4:rename %JACORB_HOME%\etc\jacorb_properties.template to %JACORB_HOME%\etc\jacorb.properties
  and modify the 50th line to 53th line to
 
       #ORBInitRef.NameService=file:/y:/nsiona.ref
      
ORBInitRef.NameService=file://d://test//NS_Ref
      
#ORBInitRef.NameService=http://www.x.y.z/~user/NS_Ref
      
#ORBInitRef.TradingService=http://www.x.y.z/~user/TraderRef
 
  modify 618th line to
       jacorb.naming.ior_filename=d://test//NS_Ref

5:rename  %JACORB_HOME%\jacotemplate.bat to %JACORB_HOME%\jaco.bat
 
  and modify related env variable
 
  rename   %JACORB_HOME%\idltemplate.bat to %JACORB_HOME%\idl.bat
  
  and modify related env variable

6:  use ant compile and build idl and java

     cd  %JACORB_HOME%\demo\grid  

     run ant
   
     the generate class file in %JACORB_HOME%\classes  and generated java file in %JACORB_HOME%\demo\grid

7: open a new cmd window:
          cd %JACORB_HOME%   ns
 
   you can see the following result:   
       [ configuration jacorb loaded from file %JAORB_HOME%\etc\jacorb.properties]

   open a new cmd window:
          cd %JACORB_HOME%   jaco demo.grid.Server
  you can see the following result:   
  [ configuration jacorb loaded from file %JAORB_HOME%\etc\jacorb.properties]
  
  open a new cmd window:
          cd %JACORB_HOME%   jaco demo.grid.client
    you can see the following result:   
 
  [ configuration jacorb loaded from file D:\work\nj\JACORB\etc\jacorb.properties]
   Height = 31
   Width = 14
   Old value at (30,13): 0.21
   Setting (30,13) to 470.11
   New value at (30,13): 470.11
   MyException, reason: This is only a test exception, no harm done :-)
   done.

由于一些原因，最近要复习一些东西，所以就把JMS的东西再复习一遍，以下便是例子

jms 中最重要的几个概念destination，ACKNOWLEDGE，subscribe,durable subscribe

destination：topic queque
  queue简单点说就是1:1 一个消息只能由一个consumer去消费，别的consumer来消费的时候已经没了，先到先得
topic简单点说就是1:N 一个消息可以由多个consumer来消费，谁来消费都有
 subscribe，拿topic来说如果当前订阅不是持久订阅，只有再订阅后生产者生产得消息才能被consumer得到，持久订阅只要没有被consumer消费，早晚会消费这个消息
 
 
 
 一下是几个例子
 
 queuesend：queque消息产生
 queuereceive：queque消息得消费
 topicsend ：topic消息得产生
 topicreceive1：topic消息的非订阅
 topicrecieve2：topic消息的持久订阅
 
 这个例子实在WEBLOGIC814上测试过的，当然要定义JMSSERVER,FACTORY,DESTINATION。
 
 
 
 QueueSend
 
 import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.Hashtable;

import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class QueueSend {
 // Defines the JNDI context factory.
 public final static String JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";

 // Defines the JNDI provider url.
 public final static String PROVIDER_URL = " t3://localhost:7001";

 // Defines the JMS connection factory for the queue.
 public final static String JMS_FACTORY = "SendJMSFactory";

 // Defines the queue.
 public final static String QUEUE = "SendJMSQueue";

 private QueueConnectionFactory qconFactory;

 private QueueConnection qcon;

 private QueueSession qsession;

 private QueueSender qsender;

 private Queue queue;

 private TextMessage msg;

 /**
  * Creates all the necessary objects for sending messages to a JMS queue.
  *
  * @param ctx
  *            JNDI initial context
  * @param queueName
  *            name of queue
  * @exception NamingException
  *                if operation cannot be performed
  * @exception JMSException
  *                if JMS fails to initialize due to internal error
  */
 public void init(Context ctx, String queueName) throws NamingException,
   JMSException {
  qconFactory = (QueueConnectionFactory) ctx.lookup(JMS_FACTORY);
  qcon = qconFactory.createQueueConnection();
  qsession = qcon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  queue = (Queue) ctx.lookup(queueName);
  qsender = qsession.createSender(queue);
  msg = qsession.createTextMessage();
  qcon.start();
 }

 /**
  * Sends a message to a JMS queue.
  *
  * @param message
  *            message to be sent
  * @exception JMSException
  *                if JMS fails to send message due to internal error
  */
 public void send(String message) throws JMSException {
  msg.setText(message);
  qsender.send(msg);
 }

 /**
  * Closes JMS objects.
  *
  * @exception JMSException
  *                if JMS fails to close objects due to internal error
  */
 public void close() throws JMSException {
  qsender.close();
  qsession.close();
  qcon.close();
 }

 /**
  * main() method.
  *
  * @param args
  *            WebLogic Server URL
  * @exception Exception
  *                if operation fails
  */
 public static void main(String[] args) throws Exception {
  try {
   InitialContext ic = getInitialContext();
   QueueSend qs = new QueueSend();
   qs.init(ic, QUEUE);
   readAndSend(qs);
   qs.close();
  } catch (Exception e) {
   e.printStackTrace();
  }
 }

 private static void readAndSend(QueueSend qs) throws IOException,
   JMSException {
  BufferedReader msgStream = new BufferedReader(new InputStreamReader(
    System.in));
  String line = null;
  boolean quitNow = false;
  do {
   System.out.print("Enter message (\"quit\" to quit): ");
   line = msgStream.readLine();
   if (line != null && line.trim().length() != 0) {
    qs.send(line);
    System.out.println("JMS Message Sent: " + line + "\n");
    quitNow = line.equalsIgnoreCase("quit");
   }
  } while (!quitNow);

 }

 private static InitialContext getInitialContext() throws NamingException {
  Hashtable env = new Hashtable();
  env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
  env.put(Context.PROVIDER_URL, PROVIDER_URL);
  return new InitialContext(env);
 }

}

QueueReceive

import java.util.Hashtable;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class QueueReceive implements MessageListener {
 // Defines the JNDI context factory.
 public final static String JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";

 // Defines the JNDI provider url.
 public final static String PROVIDER_URL = " t3://localhost:7001";

 // Defines the JMS connection factory for the queue.
 public final static String JMS_FACTORY = "SendJMSFactory";

 // Defines the queue.
 public final static String QUEUE = "SendJMSQueue";

 private QueueConnectionFactory qconFactory;

 private QueueConnection qcon;

 private QueueSession qsession;

 private QueueReceiver qreceiver;

 private Queue queue;

 private boolean quit = false;

 /**
  * Message listener interface.
  *
  * @param msg
  *            message
  */
 public void onMessage(Message msg) {
  try {
   String msgText;
   if (msg instanceof TextMessage) {
    msgText = ((TextMessage) msg).getText();
   } else {
    msgText = msg.toString();
   }

   System.out.println("Message Received: " + msgText);

//   if (msgText.equalsIgnoreCase("123")) {
//    synchronized (this) {
//     quit = true;
//     this.notifyAll(); // Notify main thread to quit
//    }
//   }
  } catch (JMSException jmse) {
   jmse.printStackTrace();
  }
 }

 /**
  * Creates all the necessary objects for receiving messages from a JMS
  * queue.
  *
  * @param ctx
  *            JNDI initial context
  * @param queueName
  *            name of queue
  * @exception NamingException
  *                if operation cannot be performed
  * @exception JMSException
  *                if JMS fails to initialize due to internal error
  */
 public void init(Context ctx, String queueName) throws NamingException,
   JMSException {
  qconFactory = (QueueConnectionFactory) ctx.lookup(JMS_FACTORY);
  qcon = qconFactory.createQueueConnection();
  qsession = qcon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  queue = (Queue) ctx.lookup(queueName);
  qreceiver = qsession.createReceiver(queue);
  qreceiver.setMessageListener(this);
  qcon.start();
 }

 /**
  * Closes JMS objects.
  *
  * @exception JMSException
  *                if JMS fails to close objects due to internal error
  */
 public void close() throws JMSException {
  qreceiver.close();
  qsession.close();
  qcon.close();
 }

 /**
  * main() method.
  *
  * @param args
  *            WebLogic Server URL
  * @exception Exception
  *                if execution fails
  */

 public static void main(String[] args) throws Exception {

  InitialContext ic = getInitialContext();
  QueueReceive qr = new QueueReceive();
  qr.init(ic, QUEUE);

  System.out
    .println("JMS Ready To Receive Messages (To quit, send a \"quit\" message).");

  // Wait until a "quit" message has been received.
  synchronized (qr) {
   System.out.println("111111111111");
   while (!qr.quit) {
    try {
     System.out.println("2222222222");
     qr.wait();
     System.out.println("333333333");
    } catch (InterruptedException ie) {
    }
   }
  }
  qr.close();
 }

 private static InitialContext getInitialContext() throws NamingException {
  Hashtable env = new Hashtable();
  env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
  env.put(Context.PROVIDER_URL, PROVIDER_URL);
  return new InitialContext(env);
 }

}

TopicSend

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.Hashtable;

import javax.jms.JMSException;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicSession;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.jms.TopicPublisher;
public class TopicSend {
 // Defines the JNDI context factory.
 public final static String JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";

 // Defines the JNDI provider url.
 public final static String PROVIDER_URL = " t3://localhost:7001";

 // Defines the JMS connection factory for the queue.
 public final static String JMS_FACTORY = "SendJMSFactory";

 // Defines the queue.
 public final static String TOPIC = "SendJMSTopic";

 private TopicConnectionFactory tconFactory;

 private TopicConnection tcon;

 private TopicSession tsession;

 private TopicPublisher tsender;

 private Topic topic;

 private TextMessage msg;
 public static InitialContext ic ;

 /**
  * Creates all the necessary objects for sending messages to a JMS queue.
  *
  * @param ctx
  *            JNDI initial context
  * @param queueName
  *            name of queue
  * @exception NamingException
  *                if operation cannot be performed
  * @exception JMSException
  *                if JMS fails to initialize due to internal error
  */
 public void init(Context ctx, String queueName) throws NamingException,
   JMSException {
  tconFactory = (TopicConnectionFactory) ctx.lookup(JMS_FACTORY);
  tcon = tconFactory.createTopicConnection();
  tsession = tcon.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
  System.out.println(topic);
  topic = (Topic) ctx.lookup(queueName);
  System.out.println(topic);
  tsender = tsession.createPublisher(topic);
  msg = tsession.createTextMessage();
  tcon.start();
 }

 /**
  * Sends a message to a JMS queue.
  *
  * @param message
  *            message to be sent
  * @exception JMSException
  *                if JMS fails to send message due to internal error
  */
 public void send(String message) throws JMSException ,NamingException{
  System.out.println(topic+"-----------");
  msg.setText(message);
  tsender.publish(msg);
 }

 /**
  * Closes JMS objects.
  *
  * @exception JMSException
  *                if JMS fails to close objects due to internal error
  */
 public void close() throws JMSException {
  tsender.close();
  tsession.close();
  tcon.close();
 }

 /**
  * main() method.
  *
  * @param args
  *            WebLogic Server URL
  * @exception Exception
  *                if operation fails
  */
 public static void main(String[] args) throws Exception {
  try {
   ic= getInitialContext();
   TopicSend ts = new TopicSend();
   ts.init(ic, TOPIC);
   readAndSend(ts);
   ts.close();
  } catch (Exception e) {
   e.printStackTrace();
  }
 }

 private static void readAndSend(TopicSend ts) throws IOException,
   JMSException,NamingException {
  BufferedReader msgStream = new BufferedReader(new InputStreamReader(
    System.in));
  String line = null;
  boolean quitNow = false;
  do {
   System.out.print("Enter message (\"quit\" to quit): ");
   line = msgStream.readLine();
   if (line != null && line.trim().length() != 0) {
    ts.send(line);
   
    System.out.println("JMS Message Sent: " + line + "\n");
    quitNow = line.equalsIgnoreCase("quit");
   }
  } while (!quitNow);

 }

 private static InitialContext getInitialContext() throws NamingException {
  Hashtable env = new Hashtable();
  env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
  env.put(Context.PROVIDER_URL, PROVIDER_URL);
  return new InitialContext(env);
 }

}

TopicReceive1

import java.util.Hashtable;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class TopicReceive1 implements MessageListener {
 // Defines the JNDI context factory.
 public final static String JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";

 // Defines the JNDI provider url.
 public final static String PROVIDER_URL = " t3://localhost:7001";

 // Defines the JMS connection factory for the queue.
 public final static String JMS_FACTORY = "SendJMSFactory";

 // Defines the queue.
 public final static String TOPIC = "SendJMSTopic";

 private TopicConnectionFactory tconFactory;

 private TopicConnection tcon;

 private TopicSession tsession;

 private TopicSubscriber tsubscriber;

 private Topic topic;

 private boolean quit = false;

 /**
  * Message listener interface.
  *
  * @param msg
  *            message
  */
 public void onMessage(Message msg) {
  System.out.println("===================");
  try {
   String msgText;
   if (msg instanceof TextMessage) {
    msgText = ((TextMessage) msg).getText();
   } else {
    msgText = msg.toString();
   }

   System.out.println("Message Received: " + msgText);

//   if (msgText.equalsIgnoreCase("123")) {
//    synchronized (this) {
//     quit = true;
//     this.notifyAll(); // Notify main thread to quit
//    }
//   }
  } catch (JMSException jmse) {
   jmse.printStackTrace();
  }
 }

 /**
  * Creates all the necessary objects for receiving messages from a JMS
  * queue.
  *
  * @param ctx
  *            JNDI initial context
  * @param queueName
  *            name of queue
  * @exception NamingException
  *                if operation cannot be performed
  * @exception JMSException
  *                if JMS fails to initialize due to internal error
  */
 public void init(Context ctx, String queueName) throws NamingException,
   JMSException {
  tconFactory = (TopicConnectionFactory) ctx.lookup(JMS_FACTORY);
  tcon = tconFactory.createTopicConnection();
  tsession = tcon.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
  topic = (Topic) ctx.lookup(queueName);
  tsubscriber = tsession.createSubscriber(topic);
  //System.out.println("12");
  //Message msg = treceiver.receive();
  //msg.acknowledge();
  //tsubscriber = tsession.createSubscriber(topic);Message msg = tsubscriber.receive();msg.acknowledge();
  //System.out.println(msg);
  tsubscriber.setMessageListener(this);
  tcon.start();
 }

 /**
  * Closes JMS objects.
  *
  * @exception JMSException
  *                if JMS fails to close objects due to internal error
  */
 public void close() throws JMSException {
  tsubscriber.close();
  tsession.close();
  tcon.close();
 }

 /**
  * main() method.
  *
  * @param args
  *            WebLogic Server URL
  * @exception Exception
  *                if execution fails
  */

 public static void main(String[] args) throws Exception {

  InitialContext ic = getInitialContext();
  TopicReceive1 tr1 = new TopicReceive1();
  tr1.init(ic, TOPIC);

  System.out
    .println("JMS Ready To Receive Messages (To quit, send a \"quit\" message).");
  
  

  // Wait until a "quit" message has been received.
//  synchronized (tr1) {
//   System.out.println("111111111111");
//   while (!tr1.quit) {
//    try {
//     System.out.println("2222222222");
//     tr1.wait();
//     System.out.println("333333333");
//    } catch (InterruptedException ie) {
//    }
//   }
//  }
  tr1.close();
 }

 private static InitialContext getInitialContext() throws NamingException {
  Hashtable env = new Hashtable();
  env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
  env.put(Context.PROVIDER_URL, PROVIDER_URL);
  return new InitialContext(env);
 }

}

TopicReceive2

import java.util.Hashtable;

import javax.jms.JMSException;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class TopicReceive2 {
 // Defines the JNDI context factory.
 public final static String JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";

 // Defines the JNDI provider url.
 public final static String PROVIDER_URL = " t3://localhost:7001";

 // Defines the JMS connection factory for the queue.
 public final static String JMS_FACTORY = "SendJMSFactory";

 // Defines the queue.
 public final static String TOPIC = "SendJMSTopic";

 private TopicConnectionFactory tconFactory;

 private TopicConnection tcon;

 private TopicSession tsession;

 private TopicSubscriber tsubscriber;

 private Topic topic;

 private boolean quit = false;

 /**
  * Creates all the necessary objects for receiving messages from a JMS
  * queue.
  *
  * @param ctx
  *            JNDI initial context
  * @param queueName
  *            name of queue
  * @exception NamingException
  *                if operation cannot be performed
  * @exception JMSException
  *                if JMS fails to initialize due to internal error
  */
 public void init(Context ctx, String queueName) throws NamingException,
   JMSException,InterruptedException {
  tconFactory = (TopicConnectionFactory) ctx.lookup(JMS_FACTORY);
  tcon = tconFactory.createTopicConnection();
  tcon.setClientID("IP10.200.7.104");
  tcon.start();
  
  tsession = tcon.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
  System.out.println("333333333333");
  topic = (Topic) ctx.lookup(queueName);
  //tsubscriber = tsession.createSubscriber(topic);
  tsubscriber= tsession.createDurableSubscriber(topic,"88888");
   for (int i=0; i<3; i++) {
             //
             TextMessage message = (TextMessage) tsubscriber.receive();
             System.out.println("message["+i+"]: " + message.getText());
         }
          Thread.sleep(10000);
  //System.out.println("12");
  //Message msg = treceiver.receive();
  //msg.acknowledge();
  //tsubscriber = tsession.createSubscriber(topic);Message msg = tsubscriber.receive();msg.acknowledge();
  //System.out.println(msg);

 }

 /**
  * Closes JMS objects.
  *
  * @exception JMSException
  *                if JMS fails to close objects due to internal error
  */
 public void close() throws JMSException {
  tsubscriber.close();
  tsession.close();
  tcon.close();
 }

 /**
  * main() method.
  *
  * @param args
  *            WebLogic Server URL
  * @exception Exception
  *                if execution fails
  */

 public static void main(String[] args) throws Exception {

  InitialContext ic = getInitialContext();
  TopicReceive2 tr2 = new TopicReceive2();
  tr2.init(ic, TOPIC);

  System.out
    .println("JMS Ready To Receive Messages (To quit, send a \"quit\" message).");
  
  

  // Wait until a "quit" message has been received.
//  synchronized (tr1) {
//   System.out.println("111111111111");
//   while (!tr1.quit) {
//    try {
//     System.out.println("2222222222");
//     tr1.wait();
//     System.out.println("333333333");
//    } catch (InterruptedException ie) {
//    }
//   }
//  }
  tr2.close();
 }

 private static InitialContext getInitialContext() throws NamingException {
  Hashtable env = new Hashtable();
  env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
  env.put(Context.PROVIDER_URL, PROVIDER_URL);
  return new InitialContext(env);
 }

}

计划任务工具 cron 的配置和说明

第一段应该定义的是：分钟，表示每个小时的第几分钟来执行。范围是从0-59
        第二段应该定义的是：小时，表示从第几个小时来执行，范围是从0-23
        第三段应该定义的是：日期，表示从每个月的第几天执行，范围从1-31
        第四段应该定义的是：月，表示每年的第几个月来执行，范围从1-12
        第五段应该定义的是：周，表示每周的第几天执行，范围从0-6，其中 0表示星期日。
        每六段应该定义的是：用户名，也就是执行程序要通过哪个用户来执行，这个一般可以省略；
        第七段应该定义的是：执行的命令和参数。
        

一、注销，关机，重启

　　注销系统的logout命令

　　1，Logout 注销是登陆的相对操作，登陆系统后，若要离开系统，用户只要直接下达logout命令即可:

　　[root@localhost root]#logout

　　Red Hat Linuxrelease 9(Shike)

　　Kernel 2.4.20.8 on an i686

　　Login: ← 回到登陆的画面

　　2，关机或重新启动的shutdown命令

　　Shutdown命令可以关闭所有程序，依照用户的需要，重新启动或关机。

　　参数说明如下:

　　 立即关机:-h 参数让系统立即关机。范例如下:

　　[root@localhost root]#shutdown –h now ← 要求系统立即关机

　　 指定关机时间:time参数可指定关机的时间;或设置多久时间后运行shutdown命令，范例如下:

　　[root@localhost root]#shutdown now ← 立刻关机

　　[root@localhost root]#shutdown +5 ← 5分钟后关机

　　[root@localhost root]#shutdown 10:30 ← 在10:30时关机

　　 关机后自动重启:-r 参数设置关机后重新启动。范例如下:

　　[root@localhost root]#shutdown -r now ← 立刻关闭系统并重启

　　[root@localhost root]#shutdown -r 23:59 ← 指定在23:59时重启动

　　3，重新启动计算机的reboot命令

　　顾名思义，reboot命令是用来重新启动系统的。常用的参数如下:

　　 -f 参数:不依正常的程序运行关机，直接关闭系统并重新启动计算机。

　　 -I 参数:在在重新启动之前关闭所有网络接口。

　　虽然reboot命令有个参数可以使用，但是一般只需要单独运行reboot命令就可以了

最近测试OMADM1.2的时候，039，040两个case是关于TLS SSL的，搞的很迷惑，最近看了一下原来TLS几乎就是SSL，基本上一摸一样而已。

Sun.com上面看到

SSL was developed by Netscape in 1994, and with input from the Internet community, has evolved to become a standard. It is now under the control of the international standards organization, the Internet Engineering Task Force (IETF). The IETF has renamed SSL to Transport Layer Security (TLS), and released the first specification, version 1.0, in January 1999. TLS 1.0 is a modest upgrade to the most recent version of SSL, version 3.0. The differences between SSL 3.0 and TLS 1.0 are minor.

所以这2个case基本上测试一个就足够了。

另外tls本来就是传输层上的一个协议，所以要是用HTTPS的话，如果你用应用服务器，比如TOMCAT WBLOGIC,他们都支持SSL，根本不需要程序实现任何东西，只要你会使用keytool生成证书就可以了。

这块只是牵扯到JSSE,具体可以到http://java.sun.com/j2se/1.4.2/docs/guide/security/jsse/JSSERefGuide.html#Introduction看

Keytool其实再JRE/LIB/SECUTITY下面的包里面，

C:\j2sdk1.4.2_05\jre\lib\security>keytool

keytool 用法：

-certreq     [-v] [-alias <alias>] [-sigalg <sigalg>]

             [-file <csr_file>] [-keypass <keypass>]

             [-keystore <keystore>] [-storepass <storepass>]

             [-storetype <storetype>] [-provider <provider_class_name>] ...

-delete      [-v] -alias <alias>

             [-keystore <keystore>] [-storepass <storepass>]

             [-storetype <storetype>] [-provider <provider_class_name>] ...

-export      [-v] [-rfc] [-alias <alias>] [-file <cert_file>]

             [-keystore <keystore>] [-storepass <storepass>]

             [-storetype <storetype>] [-provider <provider_class_name>] ...

-genkey      [-v] [-alias <alias>] [-keyalg <keyalg>]

             [-keysize <keysize>] [-sigalg <sigalg>]

             [-dname <dname>] [-validity <valDays>]

             [-keypass <keypass>] [-keystore <keystore>]

             [-storepass <storepass>] [-storetype <storetype>]

             [-provider <provider_class_name>] ...

-help

-identitydb [-v] [-file <idb_file>] [-keystore <keystore>]

             [-storepass <storepass>] [-storetype <storetype>]

             [-provider <provider_class_name>] ...

-import      [-v] [-noprompt] [-trustcacerts] [-alias <alias>]

             [-file <cert_file>] [-keypass <keypass>]

             [-keystore <keystore>] [-storepass <storepass>]

             [-storetype <storetype>] [-provider <provider_class_name>] ...

-keyclone    [-v] [-alias <alias>] -dest <dest_alias>

             [-keypass <keypass>] [-new <new_keypass>]

             [-keystore <keystore>] [-storepass <storepass>]

             [-storetype <storetype>] [-provider <provider_class_name>] ...

-keypasswd   [-v] [-alias <alias>]

             [-keypass <old_keypass>] [-new <new_keypass>]

             [-keystore <keystore>] [-storepass <storepass>]

             [-storetype <storetype>] [-provider <provider_class_name>] ...

-list        [-v | -rfc] [-alias <alias>]

             [-keystore <keystore>] [-storepass <storepass>]

             [-storetype <storetype>] [-provider <provider_class_name>] ...

-printcert   [-v] [-file <cert_file>]

-selfcert    [-v] [-alias <alias>] [-sigalg <sigalg>]

             [-dname <dname>] [-validity <valDays>]

             [-keypass <keypass>] [-keystore <keystore>]

             [-storepass <storepass>] [-storetype <storetype>]

             [-provider <provider_class_name>] ...

-storepasswd [-v] [-new <new_storepass>]

             [-keystore <keystore>] [-storepass <storepass>]

             [-storetype <storetype>] [-provider <provider_class_name>] ...

1：生成一个

C:\j2sdk1.4.2_05\jre\lib\security>keytool -genkey -alias duke -keyalg RSA   -val

idity 10 -storetype jks -keystore trust1.jks

2：查看你刚才生成的证书

C:\j2sdk1.4.2_05\jre\lib\security>keytool -list -v -keystore trust1.jks

当然要输入密码了。

但是我不太明白服务器需要2个证书1个是custom identity keystore 一个是custom trust keystore为什么2个 的输入类型不一样，一个是KeyEntry另外一个是trustedCertEntry,这个流程到底是怎样的？申请证书－>导入证书 还是不明白，请指教。

Java对象序列化学习笔记- -

beejoy 原创  来源：java研究组织

目前网络上关于对象序列化的文章不少，但是我发现详细叙述用法和原理的文章太少。本人
把自己经过经验总结和实际运用中的体会写成的学习笔记贡献给大家。希望能为整个java社
区的繁荣做一点事情。
 
序列化的过程就是对象写入字节流和从字节流中读取对象。将对象状态转换成字节流之后，
可以用java.io包中的各种字节流类将其保存到文件中，管道到另一线程中或通过网络连接
将对象数据发送到另一主机。对象序列化功能非常简单、强大，在RMI、Socket、JMS、EJB
都有应用。对象序列化问题在网络编程中并不是最激动人心的课题，但却相当重要，具有
许多实用意义。
一：对象序列化可以实现分布式对象。主要应用例如：RMI要利用对象序列化运行远程主机
上的服务，就像在本地机上运行对象时一样。
二：java对象序列化不仅保留一个对象的数据，而且递归保存对象引用的每个对象的数据。
可以将整个对象层次写入字节流中，可以保存在文件中或在网络连接上传递。利用对象序
列化可以进行对象的"深复制"，即复制对象本身及引用的对象本身。序列化一个对象可能
得到整个对象序列。
 
从上面的叙述中，我们知道了对象序列化是java编程中的必备武器，那么让我们从基础开始
，好好学习一下它的机制和用法。

java序列化比较简单，通常不需要编写保存和恢复对象状态的定制代码。实现java.io.Seri
alizable接口的类对象可以转换成字节流或从字节流恢复，不需要在类中增加任何代码。只
有极少数情况下才需要定制代码保存或恢复对象状态。这里要注意：不是每个类都可序列化，
有些类是不能序列化的，例如涉及线程的类与特定JVM有非常复杂的关系。

序列化机制：

序列化分为两大部分：序列化和反序列化。序列化是这个过程的第一部分，将数据分解成字
节流，以便存储在文件中或在网络上传输。反序列化就是打开字节流并重构对象。对象序列
化不仅要将基本数据类型转换成字节表示，有时还要恢复数据。恢复数据要求有恢复数据的
对象实例。ObjectOutputStream中的序列化过程与字节流连接，包括对象类型和版本信息。
反序列化时，JVM用头信息生成对象实例，然后将对象字节流中的数据复制到对象数据成员中。
下面我们分两大部分来阐述：

处理对象流：
（序列化过程和反序列化过程）

java.io包有两个序列化对象的类。ObjectOutputStream负责将对象写入字节流，ObjectInp
utStream从字节流重构对象。
    我们先了解ObjectOutputStream类吧。ObjectOutputStream类扩展DataOutput接口。
writeObject()方法是最重要的方法，用于对象序列化。如果对象包含其他对象的引用，则
writeObject()方法递归序列化这些对象。每个ObjectOutputStream维护序列化的对象引用表，
防止发送同一对象的多个拷贝。（这点很重要）由于writeObject()可以序列化整组交叉引用的
对象，因此同一ObjectOutputStream实例可能不小心被请求序列化同一对象。这时，进行反引用
序列化，而不是再次写入对象字节流。
下面，让我们从例子中来了解ObjectOutputStream这个类吧。

// 序列化 today's date 到一个文件中.
    FileOutputStream f = new FileOutputStream("tmp");
    ObjectOutputStream s = new ObjectOutputStream(f);
    s.writeObject("Today");
    s.writeObject(new Date());
    s.flush();

 
现在，让我们来了解ObjectInputStream这个类。它与ObjectOutputStream相似。它扩展Dat
aInput接口。ObjectInputStream中的方法镜像DataInputStream中读取Java基本数据类型的
公开方法。readObject()方法从字节流中反序列化对象。每次调用readObject()方法都返回
流中下一个Object。对象字节流并不传输类的字节码，而是包括类名及其签名。readObject()
收到对象时，JVM装入头中指定的类。如果找不到这个类，则readObject()抛出
ClassNotFoundException,如果需要传输对象数据和字节码，则可以用RMI框架。
ObjectInputStream的其余方法用于定制反序列化过程。
例子如下：

//从文件中反序列化 string 对象和 date 对象
    FileInputStream in = new FileInputStream("tmp");
    ObjectInputStream s = new ObjectInputStream(in);
    String today = (String)s.readObject();
    Date date = (Date)s.readObject();

定制序列化过程:

序列化通常可以自动完成，但有时可能要对这个过程进行控制。java可以将类声明为serial
izable，但仍可手工控制声明为static或transient的数据成员。
例子：一个非常简单的序列化类。

public class simpleSerializableClass implements Serializable{
    String sToday="Today:";
    transient Date dtToday=new Date();
}

序列化时，类的所有数据成员应可序列化除了声明为transient或static的成员。将变量声
明为transient告诉JVM我们会负责将变元序列化。将数据成员声明为transient后，序列化
过程就无法将其加进对象字节流中，没有从transient数据成员发送的数据。后面数据反序
列化时，要重建数据成员（因为它是类定义的一部分），但不包含任何数据，因为这个数据
成员不向流中写入任何数据。记住，对象流不序列化static或transient。我们的类要用
writeObject()与readObject()方法以处理这些数据成员。使用writeObject()与readObject()
方法时，还要注意按写入的顺序读取这些数据成员。
关于如何使用定制序列化的部分代码如下：

//重写writeObject()方法以便处理transient的成员。
public void writeObject(ObjectOutputStream outputStream) throws IOException{
    outputStream.defaultWriteObject();//使定制的writeObject()方法可以
                        利用自动序列化中内置的逻辑。
    outputStream.writeObject(oSocket.getInetAddress());
    outputStream.writeInt(oSocket.getPort());
}
//重写readObject()方法以便接收transient的成员。
private void readObject(ObjectInputStream inputStream) throws
IOException,ClassNotFoundException{
    inputStream.defaultReadObject();//defaultReadObject()补充自动序列化
    InetAddress oAddress=(InetAddress)inputStream.readObject();
    int iPort =inputStream.readInt();
    oSocket = new Socket(oAddress,iPort);
    iID=getID();
    dtToday =new Date();
}

完全定制序列化过程:

如果一个类要完全负责自己的序列化，则实现Externalizable接口而不是Serializable接口
。Externalizable接口定义包括两个方法writeExternal()与readExternal()。利用这些方
法可以控制对象数据成员如何写入字节流.类实现Externalizable时，头写入对象流中，
然后类完全负责序列化和恢复数据成员，除了头以外，根本没有自动序列化。这里要注意了。
声明类实现Externalizable接口会有重大的安全风险。writeExternal()与readExternal()
方法声明为public，恶意类可以用这些方法读取和写入对象数据。如果对象包含敏感信息，
则要格外小心。这包括使用安全套接或加密整个字节流。到此为至，我们学习了序列化的
基础部分知识。关于序列化的高级教程，以后再述。

1:redhat 语言设置 这个语言是安装的时候决定的,并不是每个user决定的

  /etc/sysconfig/i18n

2:redhat 模式

  /etc/inittab

id:5 xwindow  mode id:3 test mode

3:使用光驱

  挂载光驱mount /dev/hdc /mnt/cdrom

  卸载光驱时候出现 umount: /mnt/cdrom device is busy

  是因为当前的目录已经在光盘目录,应该先退出这个目录

4:安装rpm 文件

  rpm -ivh xxx.rpm  安装包

  rpm -qa |grep "tt*"  查询安装过的包

  rpm -e xxx

5:在text mode 上翻页 shift +pageup pagedown

6:ls -al
  查找隐藏的文件

7:set 查看环境变量  .bash_profile

  用户的语言设置与这个相关,如果没有设置会默认使用/etc/sysconfig/i18n

8:查看文件类型以及编码方式

  file *.file

9: 编码转换

命令名称：iconv
命令格式：iconv -f "文件目前编码" -t "文件转换后的编码" -o "转换后生成的新文件名" "源文件名"
ex: iconv -f ISO-8859 -t utf-8 -o mydoc.inc.php mydoc.inc.php.bak

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;

public class TestConn {

    public TestConn() {
        super();
    }

    public static void main(String[] args) throws Exception {
        String url = null;
        getHttpText(url);
        System.out.println("abc");
    }

    public static String getHttpText(String str) {
        URL url = null;
        try {
            url = new URL(str);
        } catch (MalformedURLException e) {
            e.printStackTrace();
        }
        HttpURLConnection huc = null;
        try {

            huc = (HttpURLConnection) url.openConnection();
            huc.setRequestMethod("GET");
            huc.setRequestProperty("Content-Type",
                    "application/vnd.syncml.dm+xml");
            // application/x-www-form-urlencoded
            // application/vnd.syncml.dm+xml
            huc.setDoOutput(true);
            huc.setRequestProperty("Cache-Control", "private");
            huc.setRequestProperty("Accept-Charset", "utf-8");
            huc.setRequestProperty("Accept", "application/vnd.syncml.dm+xml");
            huc.setRequestProperty("Content-Length", "3");
            DataOutputStream printout;
            printout = new DataOutputStream(huc.getOutputStream());
            printout.writeBytes("abc");
        } catch (IOException e) {
            e.printStackTrace();
        }
        InputStream is = null;
        try {
            is = huc.getInputStream();
        } catch (IOException e) {
            e.printStackTrace();
        }
        BufferedReader br = new BufferedReader(new InputStreamReader(is));
        StringBuffer sb = new StringBuffer();
        String line = "";
        try {
            while ((line = br.readLine()) != null) {
                sb.append(line).append("\n");
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return sb.toString();
    }

}

那么什么是理财呢？？？

很多人都很知道“理财”，也都无时无刻不在理财，但把理财说清楚的人却不多...

很多人说到理财想到的就是投资，就是开源节流，就是合理分配财产，等等… …

其实，
---------------------------------------------------------
理财就是对财富的有效管理。

理财的内涵很广，包括开源节流，包括合理分配财产，包括投资增值等，但又不止于这些。从理财的基础理论来讲，主要包括：现金管理、资产管理、债务管理、风险管理、投资管理等等。
---------------------------------------------------------
现金管理是理财的基础。包括各项收入的筹划和管理，包括各项税费的管理，包括各项日常支出的管理，包括现金的积累和短期储蓄等等。具体的管理工具和形式有各式各样的银行卡片，各式各样的储蓄方式，各种各样的支出方式，包括各种各样的节俭手段等等。

资产管理是理财的重心。资产具体包括固定资产、流动资产等。固定资产比如房产、铺面等等，流动资产包括储蓄资产、投资资产、保险资产等。资产管理是家庭理财的重点，合理有效的管理需要。

债务管理是理财的关键。债务并非完全的坏事，合理的管理债务是迅速达到理财目标的捷径，只要把债务控制在一定的合理的范围之内，对优化财务结构有很好的作用。比如在财力许可的情况下可以通过按揭提前实现高品质的家庭生活，通过金融信用延迟支付货款往来等，从而更快实现财务目标。

风险管理是理财的关键。有效的风险管理是现代社会先进的标志，没有对风险的管理交通工具不能上路运营，贸易货运不能出门出海流通，商场大厦无法入住营业，流动性和小家化也决定个人进行风险管理是大势所趋。

投资管理是理财的要点。现在很多对投资理财非常渴望，一提到投资赚钱眼睛就发亮，主要是因为目前我国金融环境不够完善，安全稳健的大众投资品种非常匮乏，很多人的收益局限于2个点以内，相较于去年初高达5个点的通货膨胀显然是一个很大的威胁。而国内居民的投资信息和能力先天不足，稍有异动即可能遭遇陷阱的现状导致国民储蓄逐年逼高。在理财范畴内投资增值是最需要专业知识的，也是实现家庭理财目标最关键的步骤。所以如何实现投资的有效管理就很重要。

总之，理财就是所有与财富有关的活动的总称，是现代社会重要的组成要素，是现代人过上幸福快乐生活必备的基本素质。

而且，五个理财的基本方面也是互相关联，互为制约，相互促进的。

做为新一代 3G 及移动终端浪潮的设备管理平台， OMA DM 技术获得了众多设备厂商和运营商的追捧，也为软件开发商提供新的崛起机会。业内目前也有不少工作在做这方面的软件。好多公司这方面的产品都是基于Sync4J开发的。

Sync4J 开源项目为我们提供了完整的 OMA DM 1.1.2 规范的 Java 实现。本文记录了 Sync4J DM Server 安装以及使用SCTS模拟器来模拟手机做一个DM业务，本文没有用PPG来通过短信方式来用真手机来做，只是用模拟器来做的。SCTS是OMA官方提供的一个测试工具，主要用来测试DMserver的，这里我们用来测试Sync4J。Sync4J和SCTS的集合是我们学习OMA的一个很好的方式。

1 ：用到以下工具。

  Oracle9i

  jboss-3.2.3

  sync4j-server-dm-1.4.9   sync4j 官方有下载

  SCTS_DeviceManagement_v1.12.zip  OMA 官方网站有下载。

2 ：安装调试

  2.1 解压文件：

   jboss-3.2.3 解压到 C:\jboss-3.2.3

把 sync4j-server-dm-1.4.9 解压到 D:\sync4j\all\server-dm .

直接安装 SCTS.

  2.2 配置环境变量

  JAVA_HOME=

  J2EE_HOME= C:\jboss-3.2.3

  SYNCSERVER_HOME= D:\sync4j\all\server-dm

2.3 修改SYNCSERVER_HOME下的几个配置文件

   SYNCSERVER_HOME\ default\config\common\properties\ Sync4j.properties

把第一行改为 server.uri=http://your IP:8080/sync4j-dm/dm

  SYNCSERVER_HOME\ install.properties 改为

(1)server-name=http://10.150.4.7:8080/sync4j-dm/dm

 (2) 用 oracle 的数据库，以下是用来连接数据库的，所以一定要配置正确。

jdbc.classpath=C:\\jboss-3.2.3\\server\\all\\lib\\ojdbc14.jar

jdbc.driver=oracle.jdbc.driver.OracleDriver

jdbc.url=jdbc:oracle:thin:@11.11.11.11:1521:abc

jdbc.user=sync4j

jdbc.password=sync4j

2 ．4以上都做完后用Sync4j自己带的安装脚本安装sync4j dm server

在 SYNCSERVER_HOME 下运行 bin\install.cmd jboss32

2 ．5由于这个版本存在了一个bug,所以在2.4做完后要修改

SYNCSERVER_HOME\bin\start.cmd

把倒数第三行 call\run.bat -c sync4j 改为

call %J2EE_HOME%\bin\run.bat -c sync4j

2 ．6 在SYNCSERVER_HOME 运行 bin\start.cmd安装

所有程序到安装到了 jboss_home 下了，可以到 JBOSS_HOME\ server\sync4j 就可以看到了，看一下你的 oralce 库里面也初始化了数据，表也建好了。

2 ．7 添加一个手机（我们其实是个模拟器）上来

http://your ip:8080/dmdemo/jsp/addDevice.jsp 填写一个 IMEI:111111111111111,

2 ．8 配置scts

Add device : IMEI:111111111111111 然后点 apply

点击 DM Account

Name ： sync4j

Server:sync4j

Con : 不用填写

Address ： http://your ip /sync4j-dm/dm

Port :8080

Server authentication:

  Digest : 找数据库用 sync4j 的数据库中， sycn4j_device 表中 :IMEI:111111111111111 ， server 的 password 为： srvpwd, 把这个 password 填写到 password 中。

Client authentication

   DIGEST: USER NAME: sync4j PASSWORD: sync4j

Add 就可以了

然后点 connect 连一下 DM SERVER 看看能否连上。 第一次一般会出现认证错我，接着再联一次就可以了， SCTS 有日志可以查看。

如果连通了那下面就来做一个采集模拟器上的一个节点吧。

http://your ip:8080/dmdemo/index.html

用 device id ： IMEI:111111111111111 login

  然后点击 add to operation list

然后用 SCTS 主动回联一下，看看 server 能够拿到这个节点的值

你会看到 6 个 message ！！！

详细看一下这 6 个 message 你会发现，这个节点的采集已经成功了！

 1 import  java.io.BufferedReader;
 2 import  java.io.InputStreamReader;
 3 import  java.security.MessageDigest;
 4
 5 import  sun.misc.BASE64Decoder;
 6 import  sun.misc.BASE64Encoder;
 7
 8 public   class  ConvertNounce  {
 9
10      //  Digest = H(B64(H(username:password)):nonce)
11      //  b1=B64(H(username:password));
12      //
13      //
14      /** */ /**
15      *  @param  args
16       */
17      public   static   void  main(String[] args)  throws  Exception  {
18         
19
20         
21      //     if(args.length!=3) throw new Exception("args is wrong ,there is must by three args :username password nextNounce");
22
23         InputStreamReader reader  =   new  InputStreamReader(System.in);
24         BufferedReader input  =   new  BufferedReader(reader);
25     
26         
27         System.out.println( " input username: " );
28         String username  = input.readLine();
29         System.out.println( " input password: " );
30         String pwd  =  input.readLine();
31         System.out.println( " input nextNounce: " );
32         
33         String serverNounce  =  input.readLine();
34         String clientNounce  =   null ;
35
36         System.out.println( "" );
37         
38         System.out.println( " userName= " + username);
39         System.out.println( " password= " + pwd);
40         System.out.println( " nextNounce= " + serverNounce);
41          byte [] b1  =  calculateDigestAndEcode64(username, pwd);
42         
43      //     System.out.println("b1="+new String(b1));
44         
45          // server 下来的nounce一定要先做B64的解码，否则算出来的结果对不上
46         serverNounce  = new  String( new  BASE64Decoder().decodeBuffer(serverNounce));
47         
48      //     System.out.println(serverNounce);
49
50          byte [] bserverNounce  =  serverNounce.getBytes();
51
52          byte [] buf  =   new   byte [b1.length  +   1   +  bserverNounce.length];
53
54         System.arraycopy(b1,  0 , buf,  0 , b1.length);
55
56         buf[b1.length]  =  ( byte )  ' : ' ;
57         System.arraycopy(bserverNounce,  0 , buf, b1.length + 1 ,
58                         bserverNounce.length);
59         MessageDigest md  =  MessageDigest.getInstance( " MD5 " );
60         
61      //     System.out.println(new String(buf));
62
63          byte [] digest  =  md.digest(buf);
64         
65      //     System.out.println(new String(digest));
66
67         clientNounce  =   new  BASE64Encoder().encode(digest);
68         System.out.println( "" );
69         System.out.println( " result Nounce= " + clientNounce);
70         
73     }
74
75      public   static   byte [] calculateDigestAndEcode64(String username,
76             String password)  throws  Exception  {
77
78         MessageDigest md  =  MessageDigest.getInstance( " MD5 " );
79         String cred  =   "" ;
80          if  (username  !=   null )  {
81             cred  =  username.trim();
82         }
83         cred  +=   " : " ;
84          if  (password  !=   null )  {
85             cred  +=  password.trim();
86         }
87      //     System.out.println(cred);
88          //  System.out.println(new String(md.digest(cred.getBytes())));
89          return   new  BASE64Encoder().encode(md.digest(cred.getBytes()))
90                 .getBytes();
91     }
92     
93     
94
95 }
96

范伟先生名言：猪撞树上了，你撞猪上了吧

  我有4种理解：
      1：猪撞树上了，你撞在猪上，猪比较软，你比猪幸运
      2：人家猪都撞树上了，你又往人家身上撞，不想让猪活了？
      3：猪往树上撞，他智商低，你比不过他，去撞猪泄愤啊？
      4：你撞了猪，猪不跟你一般见识，他去撞树

2: 安装完全采用默认就可以了，安装完可以不重启

3 ：开始菜单 ->CVSNT-> Control Panel . 停止 CVS NT

4 ：进入 repository configuration 点击 add 添加一个如图所示：

   Localtion  填写一个 D:/CVSRoot

   Name     填写 /cvs

5 ：进入 server settting

  Run as 选择一个 windows 下已有用户比如 (administrator) ，其余不用修改，应用就可以了。

6 ：进入 about :CVSNT 启动 . CVS 已经配置完毕，至于安全什么方面的东西我没有弄过。

7: 打开 eclilpse ,file->new->other ,CVS

输入 Host 、 repository path 、用户名、密码 ，其余默认，然后 next

Next

Next

Next

一切搞定，你可以建立一个目录然后 就可以commit 了 .

FUMO (Firmware Update Management Object) 手机终端用来固件升级的协议。协议主要规定了一下方面：

1 ： FIRMWARE UPDATE MANAGEMENT OBJECT PARAMETERS. （路径和节点）

2 ： BEHAVIOR ASSOCIATED WITH THE MANAGEMENT OBJECT （执行升级和下载的命令以及 ALERT ）

3 ： CLIENT INITIATED FIRMWARE UPDATE ( 手机自行发起的固件升级的一些规定 )

1 ： FIRMWARE UPDATE MANAGEMENT OBJECT PARAMETERS

总共定义如上节点

PKNAME: 升级包名字

Pkgversion: 升级包版本

Download ：用来执行初始化下载的节点

PKGURL: 初始化下载时存储的下载地址的节点

Update: 用来执行升级的节点

Pkgdata: 用来提供升级包数据的节点

Downloadnadupdate ：用来初始化下载和升级的节点

    Pkgurl ： : 初始化下载时存储的下载地址的节点

State ：手机当前升级过程中的状态。

Ext ：厂商自己定义的扩展节点

根据实现不同， FUMO 可以选择 Downloadnadupdate 也可以选择 downd and upate 这 2 个节点的组合来实现固件的升级 ( 先下载，把下载的东西放在 X/update/pkgdata 里面，然后执行升级 )

State 有一下状态

升级成功返回 100 ，根据返回的不同状态，来与 SERVER 交互。

Fumo 规定的升级过程中的流程

  FUMO 从初始化下载到最后成功然后清除掉下来后的升级包的全过程，

2 ： BEHAVIOR ASSOCIATED WITH THE MANAGEMENT OBJECT

FUMO 在执行的开始，假定手机采用先 download 然后 update, 先把升级包的 URL 从 SERVER 发过来 , 手机先自行 replace 命令把 URL 放在 Download/PkgURL 下面，然后执行 exec 命令把包下载到 update/PkgData 下面，（有的 FUMO 实现厂商采用差分包方法升级）在 update 的时候直接执行 exec 执行升级。

以下分别是执行了 2 个 exec 分别在执行 download 和 downloadandupdate.

下图是手机在进行升级过程中返回给 SERVER 的一些结果，都是用数字来表示， server 可以根据这些返回码来判断终端在升级过程中哪一步执行失败。

下图是一个终端在执行一个 download 过程和一个 update 过程的流程图，此图能够清晰的显示出 DM 的 command 与 fumo 的节点如何交互的。

下图是一个直接的 DownloadAndUpdate 的过程。手机一般会选择这两种的中的一种方式。

3 ： CLIENT INITIATED FIRMWARE UPDATE

其实这是 CP 协议的一部分内容，在下一篇文章会详细的描述 cp 协议的一些东西， cp 协议想关联有好几协议。

 DM并不是一个前沿的技术。据悉，韩国SK电讯、日本NTT DoCoMo、KDDI以及以Vodafone为首的一些欧洲运营商都已经建立起了一定规模的DM体系，它们或根据自行标准，或遵循OMA标准，现在主要提供的是以FOTA(固件更新)为主的基本功能，将来还可支持数据备份、诊断及故障修复、图形用户界面处理，甚至病毒防护等多种功能。

因为设计缺陷，Sony 与 Panasonic 曾经为手机召回蒙受了上亿美元的损失,同时中国建立手机召回制度的呼声越来越高，通信厂商该如何应对？如果因为BUG而召回手机那么岂不损失太大。终端管理在这种情况下应运而生，可以给厂商减少损失。

一句话，只要能上网支持DM的手机未来就可以在线升级操作系统，以及修复BUG等等，手机厂商和运营商会更加方便，节省成本，同时能给客户带来更好的体验。只要手机安装了支持DM协议的软件，同时有一个与之交互的SERVER，一切问题迎刃而解。

FOTA有多种实现方式，DM便是其中的一个协议

Dm 协议 5 个 package.

1: package0 server 发送通知（一般是短信）给 CLIENT ，一般通过 WAP PUSH 下去给手机。

2: package1

手机收到后 wap push 的东西后，根据 WAP PUSH 相关协议，手机会自动回联回 SERVER ， server 会得到手机的 imei, 厂商、型号等基本信息。

3:package2

Server 收到 client 的回复后，得到手机的 IP ，然后通过 HTTP 请求 client ，发送一个用户确认请求（手机必须能通过 GPRS 等方式上网），

4:package3

  手机收到后，如果用户确认 DM 继续进行，如果用户否认 DM 发送给手机一个结束标志。就是说不管 package3 用户是否确认或否认 package4 都会进行下去

5:package4

 SERVER 收到用户返回的信息不管是确认还是否认都会回复，如果 server 还想继续进行下去，那么会重复 package2 ，只是不再是简单让用户确认的东西，比如其他业务通过 DM 去取用户的版本的信息比如发送一个 GET 的 command ，最后一个 package 永远是没有任何 command 的。就是说 package2,package3 可以重复进行多次

1101:等待用户确认
1200：终端回联SERVER
1201：终端发起
1222：更多的message
1223 ：session abort

(1) ： ubuntu 6.06

(2): 由于 ubuntu 是 debian 的内核，所以要在 oracle 官方上下载 oracle-xe-universal_10.2.0.1-1.0_i386.deb

开始安装(先看下面要注意的问题，第四项)

1:dpkg –I oracle-xe-universal_10.2.0.1-1.0_i386.deb

出现一下问题

正在解压缩将用于更替的包文件 oracle-xe-universal ...

dpkg ：依赖关系问题使得 oracle-xe-universal 的配置工作不能继续：

 oracle-xe-universal 依赖于 libaio (>= 0.3.96) | libaio1 (>= 0.3.96)；然而：

  软件包 libaio还没有被安装。

  软件包 libaio1还没有被安装。

dpkg ：处理 oracle-xe-universal (--install)时出错：

  依赖关系问题 - 仍未被配置

在处理时有错误发生：

 oracle-xe-universal

原来是libaio缺少，没有安装，我就下载下来，是个rpm，然后安装这个rpm，

sudo apt-get libaio-0.3.96-7.i386.rpm

正在读取软件包列表... 完成

正在分析软件包的依赖关系树... 完成

E: 无法找到软件包 libaio-0.3.96-7.i386.rpm

真是郁闷反复试验都不行

放弃这样安装，到网上查找其他方案安装libaio

网上说采用apt-get -f install安装方式可能自动获取包

apt-get -f  install 果然可以日志如下

root@ubuntu:/home/oem# apt-get -f  install

正在读取软件包列表... 完成

正在分析软件包的依赖关系树... 完成

正在更正依赖关系... 完成

将会安装下列额外的软件包：

  libaio1

下列【新】软件包将被安装：

  libaio1

共升级了 0 个软件包，新安装了 1 个软件包，要卸载 0 个软件包，有 7 个软件未被升级。

有 1 个软件包没有被完全安装或卸载。

需要下载 5182B 的软件包。

解压缩后会消耗掉 61.4kB 的额外空间。

您希望继续执行吗？[Y/n]y

获取：1 http://mirror.lupaworld.com dapper/main libaio1 0.3.104-1ubuntu6 [5182B]下载 5182B，耗时 2s (2346B/s)

选中了曾被取消选择的软件包 libaio1。

( 正在读取数据库 ... 系统当前总共安装有 76207 个文件和目录。)

正在解压缩 libaio1 (从 .../libaio1_0.3.104-1ubuntu6_i386.deb) ...

正在设置 libaio1 (0.3.104-1ubuntu6) ...

正在设置 oracle-xe-universal (10.2.0.1-1.0) ...

Executing Post-install steps...

You must run '/etc/init.d/oracle-xe configure' as the root user to configure the database.

2 ：

root@ubuntu:/home/oem#  /etc/init.d/oracle-xe configure

Oracle Database 10g Express Edition Configuration

-------------------------------------------------

This will configure on-boot properties of Oracle Database 10g Express

Edition.  The following questions will determine whether the database should

be starting upon system boot, the ports it will use, and the passwords that

will be used for database accounts.  Press <Enter> to accept the defaults.

Ctrl-C will abort.

Specify the HTTP port that will be used for Oracle Application Express [8080]:8080

Specify a port that will be used for the database listener [1521]:1521

Specify a password to be used for database accounts.  Note that the same

password will be used for SYS and SYSTEM.  Oracle recommends the use of

different passwords for each database account.  This can be done after

initial configuration:

Confirm the password:

Do you want Oracle Database 10g Express Edition to be started on boot (y/n) [y]:y

Starting Oracle Net Listener...Done

Configuring Database...

Starting Oracle Database 10g Express Edition Instance...Done

Installation Completed Successfully.

To access the Database Home Page go to "http://127.0.0.1:8080/apex"

  这就安装完了？真是不可思以，比9I快很多啊，总共花了10几分钟，中间的配置少了好多啊。

3 ：访问数据

http://127.0.0.1:8080/apex

根据设置的密码没有问题，能够正确访问

4: 需要注意的问题：

在刚开始安装的时候可能出现一下问题

root@ubuntu:/home/oem# dpkg -i oracle-xe-universal_10.2.0.1-1.0_i386.deb

选中了曾被取消选择的软件包 oracle-xe-universal。

( 正在读取数据库 ... 系统当前总共安装有 73613 个文件和目录。)

正在解压缩 oracle-xe-universal (从 oracle-xe-universal_10.2.0.1-1.0_i386.deb) ...

This system does not meet the minimum requirements for swap space.  Based on

the amount of physical memory available on the system, Oracle Database 10g

Express Edition requires 750 MB of swap space. This system has 711 MB

of swap space.  Configure more swap space on the system and retry the installation.

dpkg ：处理 oracle-xe-universal_10.2.0.1-1.0_i386.deb (--install)时出错：

  子进程·pre-installation script·返回了错误号·1

在处理时有错误发生：

 oracle-xe-universal_10.2.0.1-1.0_i386.deb

这个问题是由于SWAP分区不够的原因造成的，那就增加一个SWAP分区

1 ：采用文件的方式增加swap分区

Dd if=/dev/zero of=/tmp/tmp.swap bs=1M count =100( 建立一个100M的文件)

mkswap /tmp/tmp.swap( 标识swap文件)

swapon /tmp/tmp.swap( 激活swap)

修改/etc/fstab文件增加一行

/tmp/tmp.swap swap swap defaluts 0 0

Swapon –s 查看当前的swap分区情况

发现已经有2个SWAP分区了，空间这下子够了，可以继续安装了

2 ：也可已采用直接增加SWAP方式（我没有采用这样的办法）

1：门前number one

在上车之前一定要占据门前的一个位置，这需要技巧，事先看准车要停的位置
一般来说车停的位置是固定的，你看那个黄色的线的颜色就可以了，要是颜色黯淡了就证明
是车门的位置，因为人员来往频繁，把黄色踩掉了，提前上车更容易找到大位置

2：车头车尾和中间

一般来说车头车尾和中间的2个车门人数较少，这是我观察的结果，从第3个车门开始人很多，
到了中间人减少一些，所以选择上车的车厢位置很关键

3：观其色，看其年龄

在西直门上车后如果没有座位一定要选择一个年长一点的有座位的，你站在边上，
据我观察，在积水谭下车的人都是些40来岁的，可能这里的国有企业比较多把，年轻人一般
在东直门，朝阳门，建国门下，特别是穿着光鲜的人，一定不要站在他座位边上，一般来说他
在外企，外企的位置基本在东直门，朝阳门，建国门，所以你就要站着了。

4：研究行为学和心理学，抢座位也要讲理
观察下车人的行为，观察没有座位人的心里，不要跟老弱病残抢，当然要礼让了

5：以上几条是常用的，还有好多没有时间总结，总之我每天基本上都有座位

图1 Servlet线程池

图2 a用户和b用户的浏览器输出

图3 Servlet实例的JMM模型

     在美国麻省Amherst学院进行了一项很有意思的实验。试验人员用很多铁圈将一个小南瓜整个箍住，以观察当南瓜逐渐地长大时，对这个铁圈产生压力有多大。最初他们估计南瓜最大能够承受大约五百磅的压力。

 

　　在实验的第一个月，南瓜承受了五百磅的压力；实验到第二个月时，这个南瓜承受了一千五百磅的压力，并且当它承受到两千磅的压力时，研究人员必须对铁圈加固，以免南瓜将铁圈撑开。

 

　　最后当研究结束时，整个南瓜承受了超过五千磅的压力后才产生瓜皮破裂。

 

　　他们打开南瓜并且发现它已经无法再食用，因为它的中间充满了坚韧牢固的层层纤维，试图想要突破包围它的铁圈。为了吸收充分的养分，以便于突破限制它成长的铁圈，它的根部甚至延展超过八万英呎，所有的根往不同的方向全方位的伸展，最后这个南瓜独自地接管控制了整个花园的土壤与资源。

 

　　我们对于自己能够变成多么坚强都毫无概念！假如南瓜能够承受如此庞大的外力，那么人类在相同的环境下又能够承受多少的压力.

检查点（checkpoint）的工作机制

检查点是一个数据库事件，它把修改数据从高速缓存写入磁盘，并更新控制文件和数据文件。

检查点分为三类：
1）局部检查点：单个实例执行数据库所有数据文件的一个检查点操作，属于此实例的全部脏缓存区写入数据文件。
触发命令：
svmrgrl>alter system checkpoint local;
这条命令显示的触发一个局部检查点。
2）全局检查点：所有实例（对应并行数据服务器）执行数据库所有所有数据文件的一个检查点操作，属于此实例的全部脏缓存区写入数据文件。
触发命令
svrmgrl>alter system checkpoint global;
这条命令显示的触发一个全局检查点。
3）文件检查点：所有实例需要执行数据文件集的一个检查点操作，如使用热备份命令alter tablespace USERS begin backup，或表空间脱机命令alter tablespace USERS offline，将执行属于USERS表空间的所有数据文件的一个检查点操作。

检查点处理步骤：
1）获取实例状态队列：实例状态队列是在实例状态转变时获得，ORACLE获得此队列以保证检查点执行期间，数据库处于打开状态；
2）获取当前检查点信息：获取检查点记录信息的结构，此结构包括当前检查点时间、活动线程、进行检查点处理的当前线程、日志文件中恢复截止点的地址信息；
3）缓存区标识：标识所有脏缓存区，当检查点找到一个脏缓存区就将其标识为需进行刷新，标识的脏缓存区由系统进程DBWR进行写操作，将脏缓存区的内容写入数据文件；
4）脏缓存区刷新：DBWR进程将所有脏缓存区写入磁盘后，设置一标志，标识已完成脏缓存区至磁盘的写入操作。系统进程LGWR与CKPT进程将继续进行检查，直至DBWR进程结束为止；
5）更新控制文件与数据文件。
注：控制文件与数据文件头包含检查点结构信息。
在两种情况下，文件头中的检查点信息（获取当前检查点信息时）将不做更新：
1）数据文件不处于热备份方式，此时ORACLE将不知道操作系统将何时读文件头，而备份拷贝在拷贝开始时必须具有检查点SCN；
ORACLE在数据文件头中保留一个检查点的记数器，在正常操作中保证使用数据文件的当前版本，在恢复时防止恢复数据文件的错误版本；即使在热备份方式下，计数器依然是递增的；每个数据文件的检查点计数器，也保留在控制文件相对应数据文件项中。
2）检查SCN小于文件头中的检查点SCN的时候，这表明由检查点产生的改动已经写到磁盘上，在执行全局检查点的处理过程中，如果一个热备份快速检查点在更新文件头时，则可能发生此种情况。应该注意的是，ORACLE是在实际进行检查点处理的大量工作之前捕获检查SCN的，并且很有可能被一条象热备份命令 alter tablespace USERS begin backup进行快速检查点处理时的命令打断。
ORACLE在进行数据文件更新之前，将验证其数据一致性，当验证完成，即更新数据文件头以反映当前检查点的情况；未经验证的数据文件与写入时出现错误的数据文件都被忽略；如果日志文件被覆盖，则这个文件可能需要进行介质恢复，在这种情况下，ORACLE系统进程DBWR将此数据文件脱机。

检查点算法描述：
脏缓存区用一个新队列链接，称为检查点队列。对缓存区的每一个改动，都有一个与其相关的重做值。检查点队列包含脏的日志缓存区，这些缓存区按照它们在日志文件中的位置排序，即在检查点队列中，缓存区按照它们的低重做值进行排序。需要注意的是，由于缓存区是依照第一次变脏的次序链接到队列中的，所以，如果在缓存区写出之前对它有另外的改动，链接不能进行相应变更，缓存区一旦被链接到检查点队列，它就停留在此位置，直到将它被写出为止。

ORACLE系统进程DBWR在响应检查点请求时，按照这个队列的低重做值的升序写出缓存区。每个检查点请求指定一个重做值，一旦DBWR写出的缓存区重做值等于或大雨检查点的重做值，检查点处理即完成，并将记录到控制文件与数据文件。
由于检查点队列上的缓存区按照低重做值进行排序，而DBWR也按照低重做值顺序写出检查点缓存区，故可能有多个检查点请求处于活动状态，当DBWR写出缓存区时，检查位于检查点队列前端的缓存区重做值与检查点重做值的一致性，如果重做值小于检查点队列前缓存区的低重做值的所有检查点请求，即可表示处理完成。当存在未完成的活动检查点请求时，DBWR继续写出检查点缓存区。

算法特点：
1）DBWR能确切的知道为满足检查点请求需要写那些缓存区；
2）在每次进行检查点写时保证指向完成最早的（具有最低重做值的）检查点；
3）根据检查点重做值可以区别多个检查点请求，然后按照它们的顺序完成处理。

SQL> show parameter log_check;

NAME                                 TYPE        VALUE
------------------------------------ ----------- ------------------------------
log_checkpoint_interval              integer     0
log_checkpoint_timeout               integer     1800
log_checkpoints_to_alert             boolean     FALSE
SQL> select checkpoint_change# from v$database;

CHECKPOINT_CHANGE#
------------------
            928767

＃＃＃＃＃＃＃＃＃＃＃＃＃＃＃＃＃＃＃＃＃＃＃＃＃＃

今天学习过程中遇到一下问题

SQL> alter database open;
alter database open
*
ERROR 位于第 1 行:
ORA-01113: 文件 1 需要介质恢复
ORA-01110: 数据文件 1: 'E:\ORACLE\ORADATA\TESTABC\SYSTEM01.DBF'

#################################
改为非归档模式
archive log stop;

#################################

SQL> recover database;
完成介质恢复。
SQL> alter database open;

数据库已更改。

可以OPERN了，

#################################
查看数据文件的状态

SQL> select name,status from v$datafile;     

##################################

1 ： agent,tnslistener 都启动起来， OracleServiceTESTDB 实例也在服务里面启动起来了

2 ： oem 档案库也建立好了，就建立在 OracleServiceTESTDB 数据库上

3 ：万事具备了，启动 OracleOraHome92ManagementServer, 报异常出来

服务器后又停止了，一些服务自动停止，如果他们没什么可做得，例如性能日志和警报服务

郁闷啊

  接下来我做了一下事情

 1 ：重新建立了档案库，然后启动 OracleOraHome92ManagementServer 仍然没有成功

 2 ： ,TNSLISTNER ， OracleOraHome92ManagementServer ， OracleServiceTESTDB ， AGENT 都设置成自动启动，重新启动了机器吧,仍然没有成功

3 ：重新安装了 ORACLE 然后重新做了以上事情，仍然没有成功

根据网上得资料和自己得实践发现一下问题

1 ：
我自己得机器是路由器给得 IP ，不是自己机器设定得固定 IP ，在 XP 下面搜索了 C:

Hosts 文件，路径 C:\WINDOWS\system32\drivers\etc\hosts

127.0.0.1       localhost

10.200.7.71     USER-3286972EF7

把分配给自己得 IP ，和自己得主机名对应一下，就是说加上第二行，然后重新启动机器，

OMS 就启动起来了，
2:
我搜索了注册表里面 OracleOraHome92ManagementServer 得

HKEY_LOCAL_MACHINE\SYSTEM\ControlSet001\Services\OracleOraHome92ManagementServer   DependOnService 数值数据对应到 OracleServiceTESTDB, 要是不对应一定要修改注册表让他对应起来，就是说一定要又依赖关系！！！！否则成功不了

总之 2 条：

  1 ：动态 IP 一定要对应主机名

  2 ：注册表里面得依赖关系一定要依赖当前档案库所在得服务上就是 OracleServiceTESTDB 上面！！！！