Quote: 引用:

关注一下
最好把代码贴一贴
接收端的

先将代码贴上，发送与接收方法，这两个方法不是在一个类里面

public void send() throws Exception{

		//获取链接工厂(ActiveMQ消息服务方式)

		ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://" + PropertiesRead.getPropertie("msg.ip") + ":" + PropertiesRead.getPropertie("msg.port"));

		//从连接工厂获取连接

		Connection connection = connectionFactory.createConnection();

		//通过连接获取JMS会话

		Session session = connection.createSession(false, QueueSession.CLIENT_ACKNOWLEDGE);	

		//获取消息目的（ActiveMQ消息服务方式）

		Destination destination = session.createQueue("MessageQueue");

		//用session创建消息生产者，并指定消息目的地

		MessageProducer messageProducer = session.createProducer(destination);

		//设置消息生产者生产的消息的 传递模式以及有效时间（非必须）

		messageProducer.setDeliveryMode(DeliveryMode.PERSISTENT);

		messageProducer.setTimeToLive(0);

//		connection.start();

                 //flag是我用来标注即将要发的消息的类型，不同类型的我做不同处理，flag可以当做是正确的，它是这个类的一个成员变量，成员变量的定义，和发送接收无关，我就不都拿出来了

		if("text".equals(flag)){

			TextMessage textMessage = session.createTextMessage();

                        //这面这一堆都是给消息添加一些需要的属性

			textMessage.setStringProperty("fromUser", ((TdAgent)request.getSession().getAttribute("loginUsers")).getAgentId());

			if(null != ((TdAgent)request.getSession().getAttribute("loginUsers")).getNickName() && !"".equals(((TdAgent)request.getSession().getAttribute("loginUsers")).getNickName())){

				textMessage.setStringProperty("fromUserName", ((TdAgent)request.getSession().getAttribute("loginUsers")).getNickName());

			}else if(null != ((TdAgent)request.getSession().getAttribute("loginUsers")).getBelongUser() && !"".equals(((TdAgent)request.getSession().getAttribute("loginUsers")).getBelongUser())){

				textMessage.setStringProperty("fromUserName", ((TdAgent)request.getSession().getAttribute("loginUsers")).getBelongUser());

			}else{

				textMessage.setStringProperty("fromUserName", ((TdAgent)request.getSession().getAttribute("loginUsers")).getAgentIp());

			}

			textMessage.setStringProperty("fromUserHead", ((TdAgent)request.getSession().getAttribute("loginUsers")).getPicture()