JMS提供一种可以在J2EE程式和元件间

Topics:

JMS&JavaMailChin-YiTsai1JMSJMS提供一種可以在J2EE程式和元件間傳送訊息的方式MessageagentJ2EE應用程式和元件使用JMSAPI和JMS溝通JMS由五個元素所組成ProviderClientMessageAdministeredobject:designationfactory,connectionNativeserver2訊息傳遞架構Point-to-point同步Subscriber/publisher3Point-to-PointMessagingClient1Client2QueuesendsacknowledgesconsumesMsgMsg4Publish/SubscribeMessagingClient1Client2publishessubscribessubscribesMsgTopicClient3deliversdelivers5ThebasicbuildingblocksofaJMSapplicationAdministeredobjectsconnectionfactoriesanddestinationsConnectionsSessionsMessageproducersMessageconsumersMessages6JMSAPIProgrammingModelConnectioncreatescreatescreatesMsgDestinationreceivesfromsendstoConnectionFactoryDestinationMessageConsumerSessionMessageProducercreates7JMSMessageTypesMessageTypeContainsSomeMethodsTextMessageStringgetText,setTextMapMessagesetofname/valuepairssetString,setDouble,setLong,getDouble,getStringBytesMessagestreamofuninterpretedbyteswriteBytes,readBytesStreamMessagestreamofprimitivevalueswriteString,writeDouble,writeLong,readStringObjectMessageserializeobjectsetObject,getObjectMessageFormat

MessageHeaderMessagePropertiesMessageBody8javax.jmsPackageConnectionEncapsulatesavirtualconnectionwithaJMSAPIproviderSessionSingle-threadedcontextforproducingandconsumingmessagesQueueSenderAnobjectcreatedbyasessionusedforsendingmessagestoaqueueQueueReceiverAnobjectcreatedbyasessionusedforreceivingmessagesfromaqueue9CreatingaPoint-to-PointJMSAPIApplication1.LookupaConnectionfactoryusingtheJ.N.D.I.API.2.LookupthemessagequeueusingtheJ.N.D.I.API.3.CreateaConnectionusingthefactory.4.CreateaSessionobject.5.CreateaMessageSenderobject.6.CreateoneormoreMessageobjects.7.SendoneormoreMessageobjectsusingtheMessageSenderobject.8.SendacontrolmessagetotheQueueobjectthatallmessageshavebeensent.10try{ INitialContextjnidiContext=newInitialContext();

queueConnectionFactory=(QueueConnectionFactory) jndiContext.lookup("QueueConnectionFactory"); queue=(Queue)jndiContext.lookup(queueName);

queueConnection=queueConnectionFactory.createQueueConnection();

queueSession=queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

queueSender=queueSession.createSender(queue);

message=queueSession.createTextMessage(); message.setText("Thisisasimplemessage”); queueSender.send(message); queueConnection.close();}catch(JMSExceptione){ System.out.println("Exceptionoccurred:"+}Sendmessage11try{ InitialContextjndiContext=newInitialContext(); factory=(QueueConnectionFactory) jndiContext.lookup("QueueConnectionFactory"); queue=(Queue)jndiContext.lookup(queueName); QueueConnectionconnection=factory.createQueueConnection(); QueueSessionsession=connection.createQueueSession(false, QueueSession.CLIENT_ACKNOWLEDGE);

receiver=session.createReceiver(queue);

receiver.setMessageListener(newMessageListener(){ publicvoidonMessage(MessagenewMessage){ try{

TextMessagemessage=(TextMessage)newMessage; System.out.println("Messagereceived"); System.out.println(message.getText());

message.acknowledge(); }catch(Exceptione){} } }); connection.start();}catch(JMSExceptione){}catch(NamingExceptione){}Receivemessage12CreatingaPublish/SubscribeJMSAPIApplication1.LookupaTopicConnectionfactoryusingtheJ.N.D.I.API.2.LookupaTopicobjectusingtheJ.N.D.I.API.3.CreateConnectionandSessionobjects.4.CreateaTopicPublisherobject.5.CreateoneormoreMessageobjects.6.PublishoneormoremessagesusingtheTopicPublisherobject.13try{ topicConnectionFactory=(TopicConnectionFactory) jndiContext.lookup("TopicConnectionFactory"); topic=(Topic)jndiContext.lookup(topicName);

topicConnection=topicConnectionFactory.createTopicConnection();

topicSession=topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);

topicPublisher=topicSession.createPublisher(topic);

message=topicSession.createTextMessage(); message.setText("Thisisasimplepublish/subscribemessage”); topicPublisher.publish(message);}catch(JMSExceptione){ System.out.println("Exceptionoccurred:"+e.toString());}Publisher14try{ TopicConnectionFactoryfactory=(TopicConnectionFactory) jndiContext.lookup("TopicConnectionFactory"); topic=(Topic)jndiContext.lookup(topicName); TopicConnectionconnection=factory.createTopicConnection(); TopicSessionsession=connection.createTopicSession(false, TopicSession.CLIENT_ACKNOWLEDGE);

subscriber=session.createSubscriber(topic);

subscriber.setMessageListener(newMessageListener(){ publicvoidonMessage(MessagenewMessage){ try{ TextMessagemessage=(TextMessage)newMessage; System.out.println("Messagereceived"); System.out.println(message.getText());

message.acknowledge(); }catch(Exceptione){} } });

connection.start();}catch(JMSExceptione){}Subscriber15JavaMail16JavaMailAPI傳送電子郵件接收電子郵件刪除電子郵件回覆和發送一封電子郵件發送電子郵件傳送附加檔案接收附加檔案搜索一個電子郵件資料夾17JavaMailAPIPackagejavax.mailClassesmodelingamailsystem.javax.mail.eventListenersandeventsfortheJavaMailAPI.ernetClassesspecifictoInternetmailsystems.javax.mail.searchMessagesearchtermsfortheJavaMailAPI.18ImportantClassesjavax.mail.SessionJavax.mail.MessageJavax.mail.AddressJavax.mail.AuthenticatorJavax.mail.TransportJavax.mail.StoreJavax.mail.Folder19MainJavamailmainclassesMessageSessionFolderTransportConnectiontoserverSendingmail

usingSMTPReceivingmailusing

POPorIMAPStoreConnectionto

aremovemailfolder

(mainlytheINBOX)Receiveandarray

ofmessagesSendingamessage收送20傳送電子郵件Session sendMailSession;

Store store;

Transport transport;

Propertiesprops=newProperties();

sendMailSession=Session.getInstance(props,null);

props.put("mail.smtp.host","");

MessagenewMessage=newMimeMessage(sendMailSession);

newMessage.setFrom(newInternetAddress(request.getParameter("from")));

newMessage.setRecipient(