如何在spark基础二次开发基于java swing的pc客户端

package org.jivesoftware.spark.ui;

import java.util.ArrayList;

import org.jivesoftware.spark.util.log.Log;

import org.jivesoftware.spark.util.ModelUtil;

import org.jivesoftware.resource.Res;

import org.jivesoftware.smack.Roster;

import org.jivesoftware.smack.RosterEntry;

import org.jivesoftware.smack.RosterGroup;

import org.jivesoftware.smack.XMPPException;

import org.jivesoftware.smack.packet.Presence;

import org.jivesoftware.smack.packet.RosterPacket;

import org.jivesoftware.smack.util.StringUtils;

import org.jivesoftware.spark.SparkManager;

import org.jivesoftware.spark.UserManager;

/**

* 处理所有订阅请求

* @author jian

*

*/

public class MySubscription {

private String jid;

//构造函数

public MySubscription(){

}

/**

* 调用

* @param jid 主键ID我爱编程网

*/

public void invoke(final String jid){

this.jid=jid;

final Roster roster=SparkManager.getConnection().getRoster();//返回好友册

//如果用户已经在好友当中，则不显示

RosterEntry entry=roster.getEntry(jid);//返回对应的用户

if(entry!=null&&entry.getType()==RosterPacket.ItemType.to){

Presence response=new Presence(Presence.Type.subscribed);

response.setTo(jid);

SparkManager.getConnection().sendPacket(response);

return;

}

UserManager userManager=SparkManager.getUserManager();

String username=userManager.getNickname(userManager.getFullJID(jid));

username=username==null?StringUtils.parseName(UserManager.unescapeJID(jid)):username;//给usernam赋值

boolean addEntry=addEntry(username);

GetGroupName();

if(addEntry){

Presence response=new Presence(Presence.Type.subscribed);

response.setTo(jid);

SparkManager.getConnection().sendPacket(response);

}

}

/**

* 同意添加好友

*/

private boolean addEntry(String username){

String errorMessage=Res.getString("title.error");

String groupName="Friends";

//获取该用户组是否存在

ContactGroup contactGroup=SparkManager.getWorkspace().getContactList().getContactGroup(groupName);

boolean isSharedGroup = contactGroup!=null&&contactGroup.isSharedGroup();

System.out.println("用户组存在?"+isSharedGroup);

if(isSharedGroup){

errorMessage=Res.getString("message.cannot.add.contact.to.shared.group");

}else if(!ModelUtil.hasLength(username)){

errorMessage=Res.getString("message.specify.contact.jid");

}else if(!ModelUtil.hasLength(groupName)){

errorMessage=Res.getString("message.specify.group");

}else if(ModelUtil.hasLength(username)&&ModelUtil.hasLength(groupName)&&!isSharedGroup){

System.out.println("添加好友");

System.out.println("直接输出Group组："+groupName);

addEntity(jid, username, groupName);

return true;

}

return false;

}

/**

* 把新用户添加到好友名单

* @param jid 账号

* @param username 昵称

* @param groupName 组名

*/

private RosterEntry addEntity(String jid,String username,String groupName){

String[] groups={groupName};

System.out.println("开始添加了哦");

for(int i=0;i

System.out.println(groups[i]);

}

Roster roster=SparkManager.getConnection().getRoster();

RosterEntry userEntry=roster.getEntry(jid);

boolean isSubscribed=true;

if(userEntry!=null){

isSubscribed=userEntry.getGroups().size()==0;

}

if(isSubscribed){

try {

roster.createEntry(jid, username, new String[]{groupName});

} catch (XMPPException e) {

Log.error("不能添加新的好友"+jid,e);

}

return roster.getEntry(jid);

}

try {

RosterGroup rosterGroup=roster.getGroup(groupName);

if(rosterGroup==null){

rosterGroup=roster.createGroup(groupName);

}

if(userEntry==null){

roster.createEntry(jid, username, groups);

userEntry=roster.getEntry(jid);

}else {

userEntry.setName(username);

rosterGroup.addEntry(userEntry);

}

userEntry=roster.getEntry(jid);

} catch (XMPPException ex) {

Log.error(ex);

}

return userEntry;

}

private void GetGroupName(){

ArrayList list=new ArrayList();

for(ContactGroup group:SparkManager.getWorkspace().getContactList().getContactGroups()){

if(!group.isOfflineGroup()&&!"Unfiled".equalsIgnoreCase(group.getGroupName())&&!group.isSharedGroup()){

list.add(group.getGroupName());

System.out.println(group.getGroupName());

}

}

}

}

首先确保SQLSERVER服务正在运行，并可以允许远程访问连接 然后按如下步骤进行连接 1.安装JDBC驱动 1)下载JDBC驱动 2)执行sqljdbc_4.0.2206.100_chs.exe解压驱动文件 3)拷贝以下目录中的sqljdbc_auth.dll到Windows的System32目录。

1. 环境准备

Eclipse 请不要使用最新的 Neon(4.6) ，太多Bug了。 还是使用最新的 Mars(4.5) 系列吧

JDK 版本8.x (Linux推荐Oracle， 没有测试过OpenJDK)

因为只是用Java，因此无需安装Scala及其相应的插件

2. 创建一个新的maven项目

3. pom.xml

org.apache.hadoop

hadoop-client

2.6.0

javax.servlet

*

org.apache.spark

spark-core_2.10

1.6.1

org.apache.spark

spark-streaming_2.10

1.6.1

org.apache.spark

spark-mllib_2.10

1.6.1

org.scala-lang

scala-library

2.10.5

这里只列出了必要的几个依赖。 其他的请根据你自己的项目需求添加

4. 使用maven打包

之后在Goal 之中填写clean package 即可

如果在修改了与Spark相关的代码之后，需要重新编译打包才行。 否则会有异常提示。

5. 代码编写注意事项：

在创建JavaSparkContext的时候，需要把自己加进去。

public static JavaSparkContextgetContext(String taskName) {

JavaSparkContextsc = new JavaSparkContext(SparkConnUtils.getSparkConf(taskName));

sc.addJar("target/sparkstat-0.0.1-SNAPSHOT.jar");

return sc;

}

其中target/sparkstat-0.0.1-SNAPSHOT.jar是maven 运行之后生成的完整的jar包