安科网

JMS实现简单聊天程序

haojing

haojing

2014-06-25

关注 关注

使用了JMS的开源实现activemq消息中间件。各版本都行

分为如下几步完成。

  第一步：安装activemq

  (1)下载解压到E:\open_source\activeMQ\apache-activemq-5.5.0，并在环境变量配置ACTIVEMQ_HOME

  (2)因为apache-activemq-5.5.0需要使用slf4j-1.5.11版本的jar包,下载slf4j

  第二步：编写相应的代码，如下：

  package ch02.chat;

import java.io.BufferedReader;   

import java.io.InputStreamReader;   


import java.util.Properties;   

  

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.TopicPublisher;   


import javax.jms.TopicSession;   


import javax.jms.TopicSubscriber;   


import javax.naming.Context;   


import javax.naming.InitialContext;   

  
  

public class Chat implements MessageListener {   

  

    private TopicSession pubSession;   


    private TopicPublisher publisher;   


    private TopicConnection connection;   


    private String username;   

  

    // 用于初始化chat的构造函数   


    public Chat(String topicFactory, String topicName, String username)   


            throws Exception {   


//      Properties env=new Properties();   


//      env.put(Context.SECURITY_PRINCIPAL, "system");   


//      env.put(Context.SECURITY_CREDENTIALS, "manager");   


//      env.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.activemq.jndi.ActiveMQInitialContextFactory");   


//      env.put(Context.PROVIDER_URL, "tcp://localhost:61616");   

           

        // 使用jndi.properties文件获得一个JNDI连接   


        InitialContext ctx = new InitialContext();   

  

        // 查找一个jms连接工厂并创建连接   

        TopicConnectionFactory conFactory = (TopicConnectionFactory) ctx   
                .lookup(topicFactory);   
        TopicConnection connection = conFactory.createTopicConnection();   
  

        // 创建两个JMS会话对象   


        TopicSession pubSession = connection.createTopicSession(false,   

                Session.AUTO_ACKNOWLEDGE);   

        TopicSession subSession = connection.createTopicSession(false,   

                Session.AUTO_ACKNOWLEDGE);   
  

        // 查找一个JMS主题   

        Topic chatTopic = (Topic) ctx.lookup(topicName);   
  

        // 创建一个JMS发布者和订阅者,createSubscriber中附加的参数是一个消息   


        // 选择器(null)和noLocal标记的一个真值,它表明这个发布者生产的消息不应被他自己所消费   

        TopicPublisher publisher = pubSession.createPublisher(chatTopic);   
        TopicSubscriber subscriber = subSession.createSubscriber(chatTopic,   

                null, true);   

  

        // 设置一个JMS消息侦听器   


        subscriber.setMessageListener(this);   

  

        // 初始化Chat应用程序变量   


        this.connection = connection;   


        this.pubSession = pubSession;   


        this.publisher = publisher;   


        this.username = username;   

  

        // 启动JMS连接，允许传递消息   

        connection.start();   
    }   
  

    // 接受来自TopicSubscriber的消息   


    public void onMessage(Message message) {   


        try {   

            TextMessage textMessage = (TextMessage) message;   
            System.out.println(textMessage.getText());   
  

        } catch (JMSException jmse) {   

            jmse.printStackTrace();   
        }   
    }   
  

    // 使用发布者创建并发送消息   


    protected void writeMessage(String text) throws JMSException {   

        TextMessage message = pubSession.createTextMessage();   

        message.setText(username + " : " + text);   

        publisher.publish(message);   
    }   
  

    // 关闭JMS连接   


    public void close() throws JMSException {   

        connection.close();   
    }   
  

    // 运行聊天客户端   


    public static void main(String[] args) {   


        try {   


            if (args.length != 3) {   


                System.out.println("Factory.Topic.or username missing");   

            }   

            String topicFactory="TopicCF";   


            String topicName="topic1";   


            String username="lyb";   


            Chat chat = new Chat(topicFactory, topicName, username);   

  

            // 从命令行读取   


            BufferedReader commandLine = new BufferedReader(   


                    new InputStreamReader(System.in));   

  

            // 循环   


            while (true) {   

                String s = commandLine.readLine();   

                if (s.equalsIgnoreCase("exit")) {   

                    chat.close();   

                    System.exit(0);   


                } else {   

                    chat.writeMessage(s);   
                }   
            }   

        } catch (Exception e) {   

            e.printStackTrace();   
        }   
        ;   
    }   
  
}  
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Properties;

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.TopicPublisher;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.naming.Context;
import javax.naming.InitialContext;


public class Chat implements MessageListener {

	private TopicSession pubSession;
	private TopicPublisher publisher;
	private TopicConnection connection;
	private String username;

	// 用于初始化chat的构造函数
	public Chat(String topicFactory, String topicName, String username)
			throws Exception {
//		Properties env=new Properties();
//		env.put(Context.SECURITY_PRINCIPAL, "system");
//		env.put(Context.SECURITY_CREDENTIALS, "manager");
//		env.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
//		env.put(Context.PROVIDER_URL, "tcp://localhost:61616");
		
		// 使用jndi.properties文件获得一个JNDI连接
		InitialContext ctx = new InitialContext();

		// 查找一个jms连接工厂并创建连接
		TopicConnectionFactory conFactory = (TopicConnectionFactory) ctx
				.lookup(topicFactory);
		TopicConnection connection = conFactory.createTopicConnection();

		// 创建两个JMS会话对象
		TopicSession pubSession = connection.createTopicSession(false,
				Session.AUTO_ACKNOWLEDGE);
		TopicSession subSession = connection.createTopicSession(false,
				Session.AUTO_ACKNOWLEDGE);

		// 查找一个JMS主题
		Topic chatTopic = (Topic) ctx.lookup(topicName);

		// 创建一个JMS发布者和订阅者,createSubscriber中附加的参数是一个消息
		// 选择器(null)和noLocal标记的一个真值,它表明这个发布者生产的消息不应被他自己所消费
		TopicPublisher publisher = pubSession.createPublisher(chatTopic);
		TopicSubscriber subscriber = subSession.createSubscriber(chatTopic,
				null, true);

		// 设置一个JMS消息侦听器
		subscriber.setMessageListener(this);

		// 初始化Chat应用程序变量
		this.connection = connection;
		this.pubSession = pubSession;
		this.publisher = publisher;
		this.username = username;

		// 启动JMS连接，允许传递消息
		connection.start();
	}

	// 接受来自TopicSubscriber的消息
	public void onMessage(Message message) {
		try {
			TextMessage textMessage = (TextMessage) message;
			System.out.println(textMessage.getText());

		} catch (JMSException jmse) {
			jmse.printStackTrace();
		}
	}

	// 使用发布者创建并发送消息
	protected void writeMessage(String text) throws JMSException {
		TextMessage message = pubSession.createTextMessage();
		message.setText(username + " : " + text);
		publisher.publish(message);
	}

	// 关闭JMS连接
	public void close() throws JMSException {
		connection.close();
	}

	// 运行聊天客户端
	public static void main(String[] args) {
		try {
			if (args.length != 3) {
				System.out.println("Factory.Topic.or username missing");
			}
			String topicFactory="TopicCF";
			String topicName="topic1";
			String username="lyb";
			Chat chat = new Chat(topicFactory, topicName, username);

			// 从命令行读取
			BufferedReader commandLine = new BufferedReader(
					new InputStreamReader(System.in));

			// 循环
			while (true) {
				String s = commandLine.readLine();
				if (s.equalsIgnoreCase("exit")) {
					chat.close();
					System.exit(0);
				} else {
					chat.writeMessage(s);
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		;
	}

}
  
  

     将以上的类复制一份，放在同一个包下面。一份代码作为消息的发布方，一份代码作为消息的订阅方。

     整个程序的工程结构组织见下图

    JMS实现简单聊天程序

    JMS实现简单聊天程序

  第三步、配置jndi文件

  java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory

  java.naming.provider.url=tcp://localhost\:61616

  java.naming.security.principal=system

  java.naming.security.credentials=manager

  connectionFactoryNames=TopicCF

  topic.topic1=jms.topic1

 第四步、启动activeMQ，分别运行Chat.java和CopyChat.java,可以在两个程序之间交互信息

jms activemq slf4j context 科技新闻

haojing

haojing

0 关注 0 粉丝 0 动态

关注 关注

相关推荐

从入门到精通的ActiveMQ（一）

话不多说，我们来一起瞧一瞧！client进程和server服务进程都必须可用，如果server出现问题或者网络故障，那么client端会收到异常。需要注意的是，JMS只是定义了Java访问消息中间件的接口，其实就是在包javax.jms中，你会发现这个包下

方新德 2020-04-20

spring整合JMS

JMS是java的一个标准，定义了使用消息代理的通用API。Spring还提供了消息驱动POJO的理念：这是一个简单的Java对象，它能够以异步的方式响应队列或主题上到达的消息。假设没有快递企业，寄件人必须亲自跋涉千里把物品送到目的地，然后由收件人去领取。

胡献根 2020-02-23

ActiveMQ简单简绍（“点对点通讯”和 “发布订阅模式”）

　　MQ全称为Message Queue, 消息队列是一种应用程序对应用程序的通信方法。应用程序通过写和检索出入列队的针对应用程序的数据（消息）来通信，而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通

胡献根 2020-02-13

开源jms服务ActiveMQ的负载均衡+高可用部署方案探索

最近公司做项目需要用到jms消息服务，最终选择了apache的activemq这个开源消息总线，但是在activemq的官网没能找到既满足高可用又满足集群部署的方案，所以探索了其集群+高可用部署方案，经试用验证ok，这里和大家分享下。ActiveMQ 是A

WindyQCF 2014-05-12

JMS - ActiveMQ - 介绍 、使用场景、优点和不足

ActiveMQ 是Apache出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现，尽管JMS规范出台已经是很久的事情了，但是JMS在当今的J2EE应用中间仍然扮演着特

lnsoftware 2014-05-11

MQ、JMS以及ActiveMQ 关系的理解

ms 的一个标准或者说是一个协议. 通常用于企业级应用的消息传递. 主要有topic 消息, queue 消息(1对1).activemq 是一个jms 的实现, apache 出的.MQ和JMS类似，但不同的是JMS是SUNJava消息中间件服务的一个

nickfover 2017-07-14

JMS基本实例

Java Message Service是java ee的规范之一，可以用来发送异步消息，在某些场景下，可以作为不同系统，或者不同模块之间的集成方式。发送的消息，只能被一个接收者取走另一种是Topic，可以被多个订阅者订阅，类似于群发ConnectionF

billmingchen 2017-08-21

ActiveMQ

　　JMS是java消息服务，JMS的客户端之间可以通过JMS服务进行异步的消息传输。客戶端成功接收一条消息的标志是一条消息被签收，成功应答。

Java高知 2019-10-20

JMS与ActiveMQ消息数据持久化

认识JMSJMS是Java消息服务，是java平台关于面向消息中间件的API。用于两个应用程序或分布式系统应用中，消息发送，消息异步处理。即应用程序间通信通过JMS服务，进行消息转发。JMS有消息异步处理、程序间解耦、消息可靠的优势。JMS消息模型Queu

胡献根 2019-10-21

局域网内linux下查看公网IP

查看公网IP的技巧：

linzx00 2012-02-24

ActiveMQ简介

当前如RMI，RPC中间件技术应用到各个领域，但面对复杂度越来越高的分布式系统，上述中间件有一下局限性：。ActiveMQ是Apache出品的流行的消息，能力较强的消息处理总线。ActiveMQ是一个完全支持JMS1.1和J2EE1.4规范的JMS Pro

Jolestar 2018-04-12

一起学ActiveMQ 01（JMS简介）

JMS API 说明书是Java程序创建，发送，接收异步消息的标准接口。许多企业J或组织实现了JMS规范说明书，就有了JMS产品，有时候叫消息中间件。现在流行的有如下几个。这个模型由消息队列queue，发送者senders，接受者receivers组成。c

activemq 2017-11-05

入浅出JMS(三)--ActiveMQ简单的HelloWorld实例

第一篇博文深入浅出JMS(一)–JMS基本概念，我们介绍了JMS的两种消息模型：点对点和发布订阅模型，以及消息被消费的两个方式：同步和异步，JMS编程模型的对象，最后说了JMS的优点。第二篇博文深入浅出JMS(二)–ActiveMQ简单介绍以及安装，我们介

Jolestar 2016-06-02

java消息机制

在JMS1.1中，公共API可被用于向一个队列或一个主题发送消息，或从其中接收消息。这7个主要的JMS公共API接口之间的关系如图1-5所示。在JMS中，是Session对象保存着用于消息传送的事务性工作单元，而不是Connection对象。这就意味着在使

liuweiITlove 2016-05-26

spring jms activemq

JMS的全称是JavaMessageService，即Java消息服务。它主要用于在生产者和消费者之间进行消息传递，生产者负责产生消息，而消费者负责接收消息。把它应用到实际的业务需求中的话我们可以在特定的时候利用生产者生成一消息，并进行发送，对应的消费者在

Jolestar 2015-04-11

使用Spring和ActiveMQ实现高效的轻量级的JMS

异步性，是高伸缩性系统的首要的设计原则，对Java来说，这意味着JMS，然后又意味着ActiveMQ。但是我如何高效的使用JMS呢？一个人很有可能会不知所措，在谈论容器、框架、和一堆选项时。那么让我们分开来探讨下。ActiveMQ文档中提及两个框架：Cam

zkpy0 2013-03-15

基于jms使用ActiveMQ实现异步日志功能.消息持久到oracle 10g 数据库

if((this==other))returntrue;Stringvisitor_ip;Stringserver_ip;Stringpage_url;Stringparameter;StringReferer_page;intVisitor_type;i

activemq 2012-11-21

一个JMS例子

按照上一讲的这个简图,首先需要得到ConnectionFactoy和Destination，这里创建一个一对一的Queue作为Destination。然后又ConnectionFactory创建一个Connection,再启动这个Connection:.

taikewu 2012-11-21

ActiveMq和RabbitMq区别及其解析

activemq: jms ---不夸平台 ----可用字节码传输，也可用json当做message的消息体。只有failover功能，即我连一个失败了，可以切换到其他的broker上。这一点貌似不太科学。AMQP为消息定义了线路层的协议，而JMS所定义的

落羽成舟 2019-07-05

Java 消息服务（JMS）介绍­­­­——使用spring与activemq

第一次写技术文章，所以不懂规矩，写得也没什么条理，主要都是根据自己的一些实际操作经验写的，关于jms，我打算会有一系列的文章，这里只是其中一节，当我们需要使用同步接收方式时就需要像同步发送消息一样使用jmstemplate。

Jolestar 2012-06-11
haojing

haojing

W3CSchool教程
HTML 教程
CSS 教程
Bootstrap 教程
Javascript 教程
jQuery 教程
后端教程
C 教程
Java 教程
PHP 教程
Python 教程
Go 教程
移动开发
Android 教程
Swift 教程
Kotlin 教程
jQuery Mobile 教程
ionic 教程
关于我们
新闻动态
联系方式
招聘英才
安科实验室
帮助与反馈

安科网(Ancii)，中国第一极客网

Copyright © 2013 - 2019 Ancii.com

京ICP备18063983号 京公网安备11010802014868号