Mule ESB java组件两种写法.docx

Mule ESB java组件两种写法1是编写java的transformer， 2 是编写java的component先说1.说到底就是一个消息的转换功能， 就是获取到http请求过来的消息(payload), 然后将其转换为自己后续需要的格式的数据形态。Java代码1. importjava.io.ByteArrayOutputStream;2. importjava.io.IOException;3. importjava.io.InputStream;4. importjava.util.HashMap;5. importjava.util.Map;6. 7. importjavax.activation.DataHandler;8. 9. importorg.mule.api.MuleEventContext;10. importorg.mule.api.MuleMessage;11. importorg.mule.api.lifecycle.Callable;12. 13. 14. 15. publicclassTransformerimplementsCallable16. 17. Override18. publicObjectonCall(MuleEventContexteventContext)throwsException19. /TODOAuto-generatedmethodstub20. 21. MuleMessagemessage=eventContext.getMessage();22. 23. /message.getPayload()得到的是通过Httpclient-MultipartEntity传过来的二进制流24. System.out.println(message.getPayload();25. InputStreamin=(InputStream)message.getPayload();26. ByteArrayOutputStreambstream=newByteArrayOutputStream();27. bytebuff=newbyte100;28. intrc=0;29. try30. while(rc=in.read(buff,0,100)0)31. bstream.write(buff,0,rc);32. 33. catch(IOExceptione)34. e.printStackTrace();35. 36. bytebytes=bstream.toByteArray();37. 38. System.out.println(-111-+bytes);39. /httpClientaddPart传过来的StringBody40. System.out.println(message.getInboundAttachmentNames();41. DataHandlerh1=message.getInboundAttachment(serviceId);42. DataHandlerh2=message.getInboundAttachment(fileName);43. System.out.println(-);44. 45. Mapmap=newHashMap();46. map.put(serviceId,h1.getContent().toString();47. map.put(fileName,h2.getContent().toString();48. map.put(payload,bytes);49. 50. returnmap;51. 52. 将http post过来的两个字符串参数 和 一个文件byte流 转换为 map形式， 目的是因为http传过来的是 multipart/form-data ， 而后面的框架代码要同时兼容application/x-www-form-urlencoded , 所以统一进行转换实现Callable 接口， 取得MuleEventContext上下文，进而获取MuleMessage。其中getPayload()得到了 inputstream ， 获取文件字节数组， 通过getInboundAttachment(serviceId) 获取到StringBody、直接返回消息实例2. component目的是改变消息set到MuleEvent ，返回eventJava代码1. importjava.io.ByteArrayOutputStream;2. importjava.io.IOException;3. importjava.io.InputStream;4. importjava.util.HashMap;5. importjava.util.Map;6. 7. importjavax.activation.DataHandler;8. 9. importorg.mule.api.MuleEvent;10. importorg.mule.api.MuleException;11. importorg.mule.api.MuleMessage;12. cessor.MessageProcessor;13. 14. publicclassMutipartTransformerimplementsMessageProcessor15. 16. Override17. publicMuleEventprocess(MuleEventevent)throwsMuleException18. 19. MuleMessagemulemessage=event.getMessage();20. 21. InputStreamin=(InputStream)mulemessage.getPayload();22. ByteArrayOutputStreambstream=newByteArrayOutputStream();23. bytebuff=newbyte100;24. intrc=0;25. try26. while(rc=in.read(buff,0,100)0)27. bstream.write(buff,0,rc);28. 29. catch(IOExceptione)30. e.printStackTrace();31. 32. bytebytes=bstream.toByteArray();33. 34. 35. System.out.println(mulemessage.getInboundAttachmentNames();36. DataHandlerh1=mulemessage.getInboundAttachment(serviceId);37. DataHandlerh2=mulemessage.getInboundAttachment(fileName);38. try39. System.out.println(h1.getContent().toString();40. catch(IOExceptione)41. e.printStackTrace();42. 43. try44. System.out.println(h2.getContent().toString();45. catch(IOExceptione)46. /TODOAuto-generatedcatchblock47. e.printStackTrace();48. 49. System.out.println(bbbbbbbbbbbbbbbbbbbbbb