?? groupitrtwin.java
字號:
package com.cn.darkblue.window;
import java.util.HashMap;
import java.util.Set;
import net.jxta.document.AdvertisementFactory;
import net.jxta.document.MimeMediaType;
import net.jxta.endpoint.Message;
import net.jxta.impl.endpoint.relay.RelayServer;
import net.jxta.impl.protocol.RelayConfigAdv;
import net.jxta.peergroup.PeerGroup;
import net.jxta.pipe.OutputPipe;
import net.jxta.protocol.PeerAdvertisement;
import net.jxta.rendezvous.RendezVousService;
import org.CoolButton;
import org.eclipse.jface.dialogs.MessageDialog;
import org.eclipse.swt.SWT;
import org.eclipse.swt.custom.StyledText;
import org.eclipse.swt.events.SelectionAdapter;
import org.eclipse.swt.events.SelectionEvent;
import org.eclipse.swt.graphics.Color;
import org.eclipse.swt.layout.FillLayout;
import org.eclipse.swt.layout.GridData;
import org.eclipse.swt.layout.GridLayout;
import org.eclipse.swt.widgets.Button;
import org.eclipse.swt.widgets.Composite;
import org.eclipse.swt.widgets.Control;
import org.eclipse.swt.widgets.Display;
import org.eclipse.swt.widgets.Group;
import org.eclipse.swt.widgets.Label;
import org.eclipse.swt.widgets.Shell;
import org.eclipse.swt.widgets.TabFolder;
import org.eclipse.swt.widgets.TabItem;
import com.cn.darkblue.entity.IFriendInfo;
import com.cn.darkblue.helper.GroupHelper;
import com.cn.darkblue.helper.IGroupChat;
import com.cn.darkblue.helper.IPGResource;
import com.cn.darkblue.listener.CFRDVListener;
import com.cn.darkblue.listener.GroupBaseCommListener;
import com.cn.darkblue.util.CFResource;
import com.cn.darkblue.util.CFUtil;
import com.cn.darkblue.util.MessageUtil;
import com.cn.darkblue.util.SysUtil;
import com.swtdesigner.SWTResourceManager;
public class GroupItrtWin extends CFShell implements IGroupChat{
public static final String CFV_KEY = "coolfaceViewKey";
public static final String LIS_KEY = "ListenerKey";
private Button f2Button;
private Button f1Button;
private Group friendGroup;
private StyledText chatInput;
private StyledText chatScreen;
HashMap headMap = null;
HashMap friMap = null;
PeerGroup peerGroup = null;
OutputPipe baseOut = null;
String cName = "";
public GroupItrtWin(Shell shell,int style,PeerGroup pg){
this(shell.getDisplay(),style,pg);
}
public GroupItrtWin(Display display, int style ,PeerGroup pg) {
super(display, style);
setText(" 組操作");
headMap = new HashMap();
friMap = new HashMap();
peerGroup = pg;
creatPanel();
cName = peerGroup.getPeerName();
CFResource.getInstance().getGroupItrtWins().add(this);
}
private void creatPanel(){
setLayout(new FillLayout());
final TabFolder tabFolder = new TabFolder(this, SWT.BORDER);
final TabItem tabItem = new TabItem(tabFolder, SWT.NONE);
tabItem.setText("聊天");
final Composite composite = new Composite(tabFolder, SWT.NONE);
final GridLayout gridLayout = new GridLayout();
gridLayout.numColumns = 2;
composite.setLayout(gridLayout);
tabItem.setControl(composite);
friendGroup = new Group(composite, SWT.NONE);
final GridLayout gridLayout_2 = new GridLayout();
friendGroup.setLayout(gridLayout_2);
final GridData gd_friendGroup = new GridData(SWT.LEFT, SWT.FILL, false, true);
friendGroup.setLayoutData(gd_friendGroup);
f1Button = new Button(friendGroup, SWT.NONE);
/*
f1Button.addSelectionListener(new SelectionAdapter() {
public void widgetSelected(SelectionEvent e) {
try{
Button but = (Button)e.getSource();
IFriendInfo fi = (IFriendInfo)but.getData(CFV_KEY);
if(fi!=null){
System.out.println("will open the chat window");
ChatWin win = new ChatWin(SysUtil.getSysShell(),SWT.SHELL_TRIM,fi.getId(),peerGroup);
win.open();
}else{
MessageDialog.openInformation(SysUtil.getSysShell()," 溫馨提示 "," 對不起還沒有綁定到好友 ");
}
}catch(Exception ex){
ex.printStackTrace();
}
}
});*/
f1Button.setText(" F1 ");
f2Button = new Button(friendGroup, SWT.NONE);
f2Button.setText(" F2 ");
/*
f2Button.addSelectionListener(new SelectionAdapter() {
public void widgetSelected(SelectionEvent e) {
try{
Button but = (Button)e.getSource();
IFriendInfo fi = (IFriendInfo)but.getData(CFV_KEY);
if(fi!=null){
System.out.println("will open the chat window");
ChatWin win = new ChatWin(SysUtil.getSysShell(),SWT.SHELL_TRIM,fi.getId(),peerGroup);
win.open();
}else{
MessageDialog.openInformation(SysUtil.getSysShell()," 溫馨提示 "," 對不起還沒有綁定到好友 ");
}
}catch(Exception ex){
ex.printStackTrace();
}
}
});*/
final Group group_1 = new Group(composite, SWT.NONE);
group_1.setLayout(new GridLayout());
group_1.setLayoutData(new GridData(SWT.FILL, SWT.FILL, true, true));
chatScreen = new StyledText(group_1, SWT.V_SCROLL | SWT.READ_ONLY | SWT.MULTI | SWT.BORDER);
final GridData gd_chatScreen = new GridData(SWT.FILL, SWT.FILL, true, true);
chatScreen.setLayoutData(gd_chatScreen);
chatInput = new StyledText(group_1, SWT.V_SCROLL | SWT.MULTI | SWT.BORDER);
final GridData gd_chatInput = new GridData(SWT.FILL, SWT.CENTER, true, false);
gd_chatInput.heightHint = 60;
chatInput.setLayoutData(gd_chatInput);
final Composite composite_1 = new Composite(group_1, SWT.NONE);
composite_1.setLayoutData(new GridData(SWT.FILL, SWT.CENTER, true, false));
final GridLayout gridLayout_1 = new GridLayout();
gridLayout_1.numColumns = 7;
composite_1.setLayout(gridLayout_1);
final Button button_2 = new Button(composite_1, SWT.NONE);
button_2.addSelectionListener(new SelectionAdapter() {
public void widgetSelected(SelectionEvent e) {
try{
HashMap map = new HashMap();
CFUtil.seatchPeer(peerGroup, map);
}catch(Exception ex){
ex.printStackTrace();
}
//MessageDialog.openInformation(SysUtil.getSysShell()," 溫馨提示 "," 查詢已經開始 ");
}
});
button_2.setText("查詢成員");
final Button button_3 = new Button(composite_1, SWT.NONE);
button_3.addSelectionListener(new SelectionAdapter() {
public void widgetSelected(SelectionEvent e) {
System.out.println("add the peer size");
bindFri();
/*
//initFreiHeader();
IPGResource pgres = (IPGResource)CFResource.getInstance().getJoinPGMap().get(peerGroup);
String mySelfId = peerGroup.getPeerID().toString();
HashMap map = pgres.getMemebers();
Object[] keys = map.keySet().toArray();
for(int i=0;i<keys.length;i++){
if(keys[i].toString().indexOf(mySelfId)!=-1) continue;
if(i==0){
System.out.println("f1Button peer is :"+keys[i]);
f1Button.setData(CFV_KEY, map.get(keys[i]));
}
if(i==1){
System.out.println("f2Button peer is :"+keys[i].toString());
f2Button.setData(CFV_KEY, map.get(keys[i]));
break;
}
}*/
}
});
button_3.setText("更新成員");
final Button f3Button = new Button(friendGroup, SWT.NONE);
f3Button.setText(" f3 ");
final Button f4Button = new Button(friendGroup, SWT.NONE);
f4Button.setText(" f4 ");
final Button f5Button = new Button(friendGroup, SWT.NONE);
f5Button.setText(" f5 ");
final Button f6Button = new Button(friendGroup, SWT.NONE);
f6Button.setText(" f6 ");
final Button f7Button = new Button(friendGroup, SWT.NONE);
f7Button.setText(" f7 ");
final Button f8Button = new Button(friendGroup, SWT.NONE);
f8Button.setText(" f8 ");
final Button act_rdvButton = new Button(composite_1, SWT.NONE);
act_rdvButton.addSelectionListener(new SelectionAdapter() {
public void widgetSelected(SelectionEvent e) {
RendezVousService rvs = peerGroup.getRendezVousService();
rvs.addListener(new CFRDVListener());
rvs.startRendezVous();
}
});
act_rdvButton.setText("ACT_RDV");
final Button con_rdvButton = new Button(composite_1, SWT.NONE);
con_rdvButton.addSelectionListener(new SelectionAdapter() {
public void widgetSelected(SelectionEvent e) {
RendezVousService rvs = peerGroup.getRendezVousService();
PeerAdvertisement adv = (PeerAdvertisement) CFUtil.loadAdvertisement(SysUtil.getRoot()+"/WAYKE.xml");
try{
rvs.addListener(new CFRDVListener());
System.out.println(" start connet to the rdv....."+adv.getPeerID().toString()+" name = "+adv.getName());
rvs.connectToRendezVous(adv);
//rvs.w
int ii = 0;
/*
while(!rvs.isConnectedToRendezVous()){
rvs.connectToRendezVous(adv);
ii++;
System.out.println(" start connet to the rdv....."+ii);
try{
Thread.sleep(5*1000);
}catch(Exception ex){
ex.printStackTrace();
}
}*/
}catch(Exception ee){
ee.printStackTrace();
}
}
});
con_rdvButton.setText("CON_RDV");
final Button button = new Button(composite_1, SWT.NONE);
button.addSelectionListener(new SelectionAdapter() {
public void widgetSelected(SelectionEvent e) {
String chats = chatInput.getText();
if(chats==null || "".equals(chats))
return;
chats = cName+" 說:"+chats;
sendPGMsg(chats);
chatInput.setText("");
}
});
button.setLayoutData(new GridData(SWT.RIGHT, SWT.CENTER, true, false));
button.setText("發送");
final Button button_1 = new Button(composite_1, SWT.NONE);
button_1.addSelectionListener(new SelectionAdapter() {
public void widgetSelected(SelectionEvent e) {
exit();
}
});
button_1.setText("退出");
final TabItem tabItem_1 = new TabItem(tabFolder, SWT.NONE);
tabItem_1.setText("資源");
this.setSize(500, 400);
this.setText("組:"+peerGroup.getPeerGroupName());
startRelay();
//initFreiHeader();
}
private void startRelay(){
try{
RelayConfigAdv rca = (RelayConfigAdv)AdvertisementFactory.newAdvertisement(RelayConfigAdv.getAdvertisementType());
rca.setServerEnabled(true);
rca.setClientEnabled(true);
//rca.setAclUri(arg0);
//rca.setAclUri(arg0)
System.out.println("the Relay Adv \n"+rca.getDocument(MimeMediaType.XMLUTF8));
//peerGroup.refRelayProtoSpecID
//rca.
}catch(Exception e){
e.printStackTrace();
}
//RelayServer srv = new RelayServer(peerGroup,"wayke01",);
}
private void bindFri(){
IPGResource pgres = (IPGResource)CFResource.getInstance().getJoinPGMap().get(peerGroup);
String mySelfId = peerGroup.getPeerID().toString();
HashMap map = pgres.getMemebers();
System.out.println("All Friends :"+map.size());
Control[] objs = friendGroup.getChildren();
Object[] keys = map.keySet().toArray();
Button btn = null;
FriChatClickListener lis;
int index = 0;
for(int i=0;i<keys.length;i++){
if(keys[i].toString().indexOf(mySelfId)!=-1) continue;
if(index<objs.length){
btn = (Button)objs[index];
IFriendInfo fi = (IFriendInfo)map.get(keys[i]);
System.out.println("Friend Name is :"+fi.getName());
System.out.println("Friend Name ID :"+fi.getId());
btn.setText(fi.getName());
btn.setData(CFV_KEY, fi);
lis = (FriChatClickListener)btn.getData(LIS_KEY);
if(lis!=null)
btn.removeSelectionListener(lis);
lis = new FriChatClickListener();
btn.addSelectionListener(lis);
btn.setData(LIS_KEY, lis);
index ++;
}
}
}
public void exit(){
close();
}
private void initFreiHeader(){
IPGResource pgres = (IPGResource)CFResource.getInstance().getJoinPGMap().get(peerGroup);
HashMap map = pgres.getMemebers();
Object[] keys = map.keySet().toArray();
for(int i=0;i<keys.length;i++){
System.out.println("peer is :"+keys[i].toString());
addFreiHeader(map.get(keys[i]));
}
}
private CoolButton getButton(Group group, String title) {
return null;
}
private void sendPGMsg(String msg){
if(baseOut==null){
IPGResource pgres = (IPGResource)CFResource.getInstance().getJoinPGMap().get(peerGroup);
baseOut = (OutputPipe)pgres.getOutputPipes().get(GroupHelper.PIPE_OUT_KEY);
GroupBaseCommListener listener = (GroupBaseCommListener)pgres.getInputListener().get(GroupBaseCommListener.BASE_COMM_KEY);
try{
listener.setScreen(this);
}catch(Exception e){
e.printStackTrace();
}
}
Message sMsg = new Message();
MessageUtil.addStringToMessage(sMsg,GroupBaseCommListener.BASE_COMM_NAMESPACE, GroupBaseCommListener.CHAT_STR, msg);
MessageUtil.addIntegerToMessage(sMsg,GroupBaseCommListener.BASE_COMM_NAMESPACE, GroupBaseCommListener.RES_CMD_STR, GroupBaseCommListener.CHAT_PGALL_CMD);
try{
baseOut.send(sMsg);
}catch(Exception e){
e.printStackTrace();
}
}
////////////////////IGroupChat/////////////////
public boolean addFreiHeader(Object header){
IFriendInfo fi = (IFriendInfo)header;
friMap.put(fi.getId(),fi);
headMap.put(fi.getId(),getButton(friendGroup,"cc"));//fi.getName()
return true;
}
public boolean removeFreiHeader(Object header){
return true;
}
public void sendMessage(Object msg){
//TODO 選擇管道 發送消息
}
public void jitterHeader(Object obj){
IFriendInfo fi = (IFriendInfo)obj;
CoolButton cb = (CoolButton)headMap.get(fi.getId());
Color cr1 = SWTResourceManager.getColor(0, 0, 0);
cb.setClr1(cr1);
cb.redraw();
}
public void print(String message) {
String value = chatScreen.getText();
if(value == null) value="";
chatScreen.setText(value+message);
chatScreen.setSelection((value+message).length());
}
public void println(String message) {
String value = chatScreen.getText();
if(value == null) value="";
chatScreen.setText(value+message+"\n");
chatScreen.setSelection((value+message).length());
}
public PeerGroup getPeerGroup() {
return peerGroup;
}
public void setPeerGroup(PeerGroup peerGroup) {
this.peerGroup = peerGroup;
}
class FriChatClickListener extends SelectionAdapter{
public void widgetSelected(SelectionEvent e) {
try{
Button but = (Button)e.getSource();
IFriendInfo fi = (IFriendInfo)but.getData(CFV_KEY);
if(fi!=null){
System.out.println("will open the chat window");
ChatWin win = new ChatWin(SysUtil.getSysShell(),SWT.SHELL_TRIM,fi.getId(),peerGroup,fi.getName());
win.open();
}else{
MessageDialog.openInformation(SysUtil.getSysShell()," 溫馨提示 "," 對不起還沒有綁定到好友 ");
}
}catch(Exception ex){
ex.printStackTrace();
}
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -